开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink1.14.6 用jdbc connector 报这样的错,各位大佬有遇到过吗?

问题1:flink1.14.6 用jdbc connector 报这样的错,各位大佬有遇到过吗?image.png 问题2:其实主要是在插入mysql环节报这个错,使用flink sql 方式,没有报任何错,但是mysql里面没数据;使用flink DataStream方式的connector 就报这样的错,如果是版本冲突的话,我从哪下手查呢,我是从mysql读数据,然后写入另一个表,可以读出来数据,但是写不进去

展开
收起
真的很搞笑 2023-07-02 11:51:34 129 0
3 条回答
写回答
取消 提交回答
  • 对于您的问题,报错信息有点模糊,但可能的原因如下:

    问题1:flink-connector-jdbc 报错 - 缺少 flink-connector-jdbc 相关依赖:请确保您的项目中引入了 flink-connector-jdbc 和 flink-sql-connector-jdbc 等相关依赖,并且版本与 Flink 1.14.6 匹配。 - 依赖版本不匹配:请确保 Flink 和 flink-connector-jdbc 的版本一致。可以尝试升级或降级 flink-connector-jdbc 的版本来解决冲突。 - 类加载路径问题:检查类加载路径是否正确包含了 flink-connector-jdbc 的 JAR 包。

    问题2:插入 MySQL 报错 - 依赖版本不匹配:确保 flink-connector-jdbc 的版本与 Flink 一致。 - 数据库连接配置错误:检查您的连接字符串、用户名和密码等数据库连接配置是否准确。 - 网络问题:检查网络连通性,确保可以正常访问 MySQL 数据库。 - 依赖作用域设置错误:检查 Maven 依赖是否正确设置,以确保 flink-connector-jdbc 被正确引入。

    在解决问题时,您可以逐个排除这些可能的原因。同时,查看日志文件可能会提供更多详细的错误信息,有助于定位问题的根本原因。

    2023-07-30 13:13:23
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    这可能是以下几个原因造成的:
    flink-connector-jdbc相关依赖缺失
    需要确保你的项目中引入了如下依赖:
    flink-connector-jdbc
    flink-sql-connector-jdbc
    flink-connector-base_2.13 等
    依赖版本不匹配
    Flink 和 flink-connector-jdbc 的版本必须保持一致。
    类加载路径有问题
    需要检查你的类加载路径(classpath)是否正确包含了flink-connector-jdbc的jar包。
    网络问题,无法下载相关依赖
    请检查项目是否能访问外网,以下载相关的依赖。
    依赖作用域设置有误
    请检查你依赖flink-connector-jdbc的方式,如maven依赖是否设置正确。
    具体来说,需要如下maven依赖:
    xml
    Copy


    org.apache.flink
    flink-connector-jdbc_2.12
    1.14.0


    org.apache.flink
    flink-sql-connector-jdbc_2.12
    1.14.0

    希望以上信息能为你定位

    2023-07-30 11:02:36
    赞同 展开评论 打赏
  • 回答1:看下依赖的jar版本 是否有冲突问题 回答2:sql和 DataStream connector 是两个不同的jar依赖,此回答整理自钉群“Flink CDC 社区”

    2023-07-02 12:01:49
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载