"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.
我下载了好几个版本的jdbc都不行,请问那个版本是适合Flink 1.17.0 的?https://mvnrepository.com/artifact/org.apache.flink/flink-connector-jdbc"
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
请检查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和连接器会减少兼容性问题。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。