我下载了好几个版本的jdbc都不行,请问那个版本是适合Flink 1.17.0 的?

"2023-08-04 17:43:58org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: org.apache.flink.connector.jdbc.internal.GenericJdbcSinkFunctionClassLoader info: URL ClassLoader: file: '/tmp/tm_localhost:45768-254db4/blobStorage/job_bee2f56d15c9fe6e5988c1b8d685af30/blob_p-4c7d1cc1f370527621f54d71f7c0aa5f5fc20b14-901d246d7092ce426835bef00cdb0c33' (valid JAR) file: '/tmp/tm_localhost:45768-254db4/blobStorage/job_bee2f56d15c9fe6e5988c1b8d685af30/blob_p-bee7ac20b7171117bce9f5f551d9d16fd70db2ae-016b442b16daace24f0b76b416859a34' (valid JAR)Class not resolvable through given classloader.
d236f02358015a1f6b749eba7de1871f.png
我下载了好几个版本的jdbc都不行,请问那个版本是适合Flink 1.17.0 的?https://mvnrepository.com/artifact/org.apache.flink/flink-connector-jdbc"

展开
收起
十一0204 2023-08-09 10:15:28 632 分享 版权
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    请检查Flink版本和JDBC连接器版本是否兼容:

    Flink 1.17.0推荐使用flink-jdbc_2.12-1.17.0.jar连接器。

    该连接器需要sql-client_2.12-1.17.0.jar作为依赖。

    如果使用其它版本JDBC连接器,请确认与Flink核心版本兼容。

    检查点要注意:

    Flink 1.11后的版本,JDBC连接器不再内置,需要单独添加依赖。

    旧版本连接器可能与新Flink不兼容导致类加载问题。

    可以尝试:

    删除原连接器,重新添加flink-jdbc_2.12-1.17.0.jar与依赖

    升级Flink核心到匹配连接器版本

    降级连接器到低于1.11的版本测试兼容性

    查看日志定位类加载异常类全名

    一般来说,匹配相同MAJOR.MINOR版本的Flink和连接器会减少兼容性问题。

    2023-08-10 22:53:29
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理