请教大佬们,flink可以指定使用对应sql-connector包吗,我现在有个需求,需要要把数据写到es6或者es7里面,但是把两个对应的es连接器包都放到lib下面时会报错,有什么解决方案吗?连接器标识是不一样的,我试一下,之前同事说是不开行的,我还没试过,这个就很恼火,我们领导不管这些,我们这个是做数据集成,公司内部部门太多,所以很多组件版本不统一,不放到lib下怎么加载呢,之前我试过用-C指定jar包不行,sql-client用-l倒是可以
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
应该可以分别把几个版本的connector源码下下来,然后改连接器的标识,自己编译之后,再放过去,es7的客户端可以直接写es6,看下报错信息是什么吧,估计包名和META-INF里面也要改,es6 和 es7特性有区别。我们也是两个一起用的,不要放到flink lib下就行了,flink run 提交到yarn上,此回答整理自钉群“Flink CDC 社区”