Flink CDC 中还有 缺少包的错误 之前在cdc 里面 查询一张表的时候也有这个错误

Flink CDC 中还有 缺少包的错误 之前在cdc 里面 查询一张表的时候也有这个错误 您有遇到过么 image.png 我flink lib 里面已经添加了 kafka connect jar包了,查询一张表 也会有这个错误 jar 包都试了好几个 image.png 是这个吧image.png 包名称 是flink-shaded-kafka-clients 么 还是 不行 有没有缺少啥包的 image.png image.png 我的包 全部都在这了 还有缺少啥包的吗 大佬指教一下 ,请教一下 两位大佬 还有没有缺少啥包的 image.png 我没用 idea 我只接提交一个yarn-session 然后 sql搞起来

展开
收起
真的很搞笑 2023-05-02 08:03:49 192 分享 版权
1 条回答
写回答
取消 提交回答
  • 应该放kafka sql connector包,是的,这个里面应该有shade kafka client了,你的kafka client包应该不用了image.png https://github.com/apache/flink-connector-kafka/blob/main/flink-sql-connector-kafka/pom.xmlsql jar 包含这些依赖了,就不用自己加到lib了,如果不是真的要用的话这个包不需要,你吧报错信息发我,我一般都是idea打包提交,打成胖包,此回答整理自钉群“Flink CDC 社区”

    2023-05-02 23:18:08
    赞同 展开评论

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

还有其他疑问?
咨询AI助理