Flink CDC中为啥两个flink sql一样的作业,一个版本是vvr-6.0.4-flink-1.15,另一个是vvr-4.0.16-flink-1.13。低版本的运行的很快,那个高版本的很慢?
Flink CDC 是基于 Flink 技术的一个开源实时数据同步工具,可以实现从 MySQL、PostgreSQL、Oracle 等关系型数据库中实时同步数据到 Flink 流处理引擎中进行实时处理。而 VVR(Virtual View Replication) 是一种基于 CDC 技术的数据同步方案,可以实现对数据库中的视图进行实时同步。
根据您的描述,您可能遇到了两个 Flink SQL 作业,一个是使用 VVR 6.0.4-flink 版本,另一个没有使用 VVR。
在 Flink CDC 中,VVR 是一种特殊的数据同步方案,它基于 CDC 技术,可以实现对视图的实时同步。因此,如果您使用了 VVR,那么在您的 Flink SQL 作业中,可能会使用 VVR 提供的相关 API 或者配置参数来进行视图同步操作。
如果您的两个 Flink SQL 作业一样,但一个使用了 VVR,一个没有使用 VVR,那么可能是因为您在配置文件或者代码中启用了或者禁用了 VVR。建议您检查配置文件和代码,确认 VVR 是否被启用,并进行相应的调整。
或者官网提供的接口,类似mongodb的的changstream,最好还是用vvr-4.0.16-flink-1.13低版本的,高版本的有好几个问题。,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。