开发者社区 > 大数据与机器学习 > 正文

现在的Flink CDC问题是,升级后其他版本各种不兼容,处理掉后又会出现新的?

现在的Flink CDC问题是,升级后其他版本各种不兼容,处理掉后又会出现新的 java.lang.ClassNotFoundException: org.apache.flink.connector.base.source.reader.splitreader.SplitReader 所以想请教下,其他包的版本是否有标准?现在需要用到 指定时间戳进行数据同步功能,所以版本升级了下 flink :1.16.0 flink cdc :2.3.0 mysql-connector-java:8.0.30 flink-clients_2.12:1.13.6 flink-java:1.16.0 flink-streaming-java_2.12:1.13.6 flink-table-api-scala-bridge_2.12:1.16.0 flink-table-planner_2.12:1.16.0

展开
收起
真的很搞笑 2023-06-11 16:36:47 76 0
1 条回答
写回答
取消 提交回答
  • 建议用1.16的最大小版本,此回答整理自钉群“Flink CDC 社区”

    2023-06-11 16:49:50
    赞同 展开评论 打赏

大数据领域前沿技术分享与交流,这里不止有技术干货、学习心得、企业实践、社区活动,还有未来。

相关产品

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

    热门文章

    相关电子书

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