Flink这个问题怎么解决?我这边自定义连接器的话,测试下来不同版本的vvr也是可以的,sql方式全都可以拿到增量快照的数据同时测试了本地idea和本地flink cluster,对于不同版本的mongo也测试了,但是可以拿到数据,证明没问题。然后又测试了,flink 1.17 、1.15 上vvr,开源mongodb-cdc 2.4.x就是拿不到数据,。只是简单的 ds.print()。控制台一直是没有任何输出。vvr的输出
本地cluster的输出
对于您在Flink 1.17和1.15版本上使用vvr和开源mongodb-cdc 2.4.x无法获取数据的问题,可能的原因有很多。首先,需要确认的是,MongoDB CDC是Flink CDC社区提供的一个用于捕获变更数据的Flink连接器。该连接器可以连接到MongoDB数据库和集合,并捕获其中的数据变更。
如果您的自定义连接器在不同的环境和版本中表现不一致,那么可能的原因包括但不限于:网络问题、配置问题、依赖问题等。为了解决这个问题,您可以采取以下步骤:
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。