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

运行flink 任务报这个错,是因为mysql 的连接jar 包版本问题吗?

运行flink 任务报这个错,是因为mysql 的连接jar 包版本问题吗?lALPM5VwHvK-gGHNAqzNCvk_2809_684.png
lALPM4c6JF-k6SHM7s0GLA_1580_238.png

展开
收起
三分钟热度的鱼 2024-06-26 22:20:39 42 0
1 条回答
写回答
取消 提交回答
  • 作业里cdc表使用的 server id 和其他表或其他作业里的表,或其他同步工具使用的server id 冲突了,server id 需要全局唯一,server id 是一个int类型整数。 在 CDC 2.x 版本中,source 的每个并发都需要一个server id,建议合理规划好server id,比如作业的 source 设置成了四个并发,可以配置 'server-id' = '5001-5004', 这样每个 source task 就不会冲突了。
    作业使用server-id不能重复,每个并发都需要一个,'server-id' = '5001-5004' 这种格式
    此回答整理自钉群“实时计算Flink产品外部客户交流群”

    2024-06-27 08:04:02
    赞同 2 展开评论 打赏

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

相关产品

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

    热门文章

    相关电子书

    更多
    One Box: 解读事务与分析一体化数据库 HybridDB for MySQL 立即下载
    One Box:解读事务与分析一体化数据库HybridDB for MySQL 立即下载
    如何支撑HTAP场景-HybridDB for MySQL系统架构和技术演进 立即下载

    相关镜像