Flink CDC 中还有 缺少包的错误 之前在cdc 里面 查询一张表的时候也有这个错误 您有遇到过么
我flink lib 里面已经添加了 kafka connect jar包了,查询一张表 也会有这个错误 jar 包都试了好几个
是这个吧
包名称 是flink-shaded-kafka-clients 么 还是 不行 有没有缺少啥包的
我的包 全部都在这了 还有缺少啥包的吗 大佬指教一下 ,请教一下 两位大佬 还有没有缺少啥包的
我没用 idea 我只接提交一个yarn-session 然后 sql搞起来
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
应该放kafka sql connector包,是的,这个里面应该有shade kafka client了,你的kafka client包应该不用了
https://github.com/apache/flink-connector-kafka/blob/main/flink-sql-connector-kafka/pom.xmlsql jar 包含这些依赖了,就不用自己加到lib了,如果不是真的要用的话这个包不需要,你吧报错信息发我,我一般都是idea打包提交,打成胖包,此回答整理自钉群“Flink CDC 社区”