请教大佬们,flink可以指定使用对应sql-connector包吗,我现在有个需求,需要要把数据?

请教大佬们,flink可以指定使用对应sql-connector包吗,我现在有个需求,需要要把数据写到es6或者es7里面,但是把两个对应的es连接器包都放到lib下面时会报错,有什么解决方案吗?连接器标识是不一样的,我试一下,之前同事说是不开行的,我还没试过,这个就很恼火,我们领导不管这些,我们这个是做数据集成,公司内部部门太多,所以很多组件版本不统一,不放到lib下怎么加载呢,之前我试过用-C指定jar包不行,sql-client用-l倒是可以

展开
收起
真的很搞笑 2023-05-14 21:17:37 141 分享 版权
1 条回答
写回答
取消 提交回答
  • 应该可以分别把几个版本的connector源码下下来,然后改连接器的标识,自己编译之后,再放过去,es7的客户端可以直接写es6,看下报错信息是什么吧,估计包名和META-INF里面也要改,es6 和 es7特性有区别。我们也是两个一起用的,不要放到flink lib下就行了,flink run 提交到yarn上,此回答整理自钉群“Flink CDC 社区”

    2023-05-14 21:20:58
    赞同 展开评论

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

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