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

Flink CDC 里提示少包但已经把jar包放进去了。还是一样的报错 正确的应该是哪个啊?

我在使用 Flink CDC 时遇到了缺少包的错误,尽管已经添加了相应的 jar 包,仍然出现同样的报错。已按照提示添加相应的 jar 包,还有可能是哪些依赖冲突导致的问题?目前使用的是以下这些 jar 包:
5a0bc7fadb34544bc068af62c42fee7a.pngbbf3f444ffef1f5204a8ad3e0cb3e3dd.png
16cbd2ae6fa0399473303104cb8f0e5d.pnged1963c890779b67f8ae5026d944fa37.png5f821a7cb51fee0ac05ee345c43f372e.png

展开
收起
小小鹿鹿鹿 2024-03-11 16:51:29 19 0
1 条回答
写回答
取消 提交回答
  • 这个是包冲突 。应该是kafka。1:flink-connector-mysql-cdc 中过滤掉kafka依赖
    2:以上不行的话 看下 flink-kafka/flink-sql-kafka这两个架包干掉一个。我这边就这些就行了,搞了个临时的解决方案,类加载改成了 parent-first,然后打包就可以了。676d3dd5b429fa4555cdc2b74048080e.png此回答来自钉群Flink CDC 社区 。

    2024-03-11 22:20:08
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

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