Flink CDC中flink 2.3升级到2.4,有什么代码变化吗?升级之后没有数据了。
从 Flink 2.3 升级到 2.4,Flink CDC 中的代码变化可能会有以下几个方面:
Flink 版本升级:Flink 2.4 对 Flink 2.3 进行了一些改进和优化,例如性能提升、稳定性改进和新特性添加等。在升级 Flink 版本时,需要注意 Flink 的 API 和配置可能存在变化。
CDC Connector 变化:Flink CDC Connector 是 Flink 用于实现增量数据同步的核心组件。在 Flink 2.4 中,CDC Connector 可能会进行一些改进和优化,例如支持新的数据源、增强性能等。在升级 Flink 版本时,需要注意 CDC Connector 的变化。
API 变化:Flink 2.4 中可能会有一些 API 的变化,例如新增或删除 API、API 参数的变化等。在升级 Flink 版本时,需要注意 API 的变化,并相应地进行修改。
配置变化:Flink 2.4 中可能会有一些配置项的变化,例如新增或删除配置项、配置项参数的变化等。在升级 Flink 版本时,需要注意
新增了一些功能和改进,Flink CDC 2.4支持Vitess数据源,更多连接器支持增量快照,升级Debezium版本等 。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。