Flink-cdc-3.0支持sqlserver、oracle的schema change吗?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
Flink CDC 3.0 是否支持 SQL Server 和 Oracle 的 Schema Change,需要从社区版和商业版连接器的功能支持情况以及相关配置能力进行分析。
根据知识库中的描述,SQL Server CDC 和 Oracle CDC 属于社区版连接器。社区版连接器遵循 Apache 2.0 开源协议,其功能支持与阿里云商业版连接器存在差异。具体来说: - 社区版连接器的 Schema Change 支持依赖于开源社区的实现。 - 阿里云不提供针对社区版连接器的技术支持,用户需自行在开源社区寻求解决方案。
因此,Flink CDC 3.0 社区版是否支持 SQL Server 和 Oracle 的 Schema Change 取决于开源社区的具体实现。
对于商业版连接器,知识库中提到 Flink CDC 商业版支持 Schema Evolution 功能,但仅明确提到了 MySQL CDC、Postgres CDC(公测中)和 MongoDB CDC(公测中)作为商业化的连接器。对于 SQL Server 和 Oracle 的商业版连接器,知识库中并未明确说明其是否支持 Schema Change。
即使连接器本身支持 Schema Change,其处理方式也依赖于 schema.change.behavior
配置项。以下是常见的 Schema Change 处理模式: - LENIENT(默认):对 Schema 变更进行转换,使其适应目标端的能力。例如,新增列会被设置为可空列,删除列会填充为 NULL 值。 - EVOLVE:将所有 Schema 更改应用于目标端。如果目标端不支持某些变更,作业会抛出异常并触发故障重启。 - EXCEPTION:不允许任何 Schema 变更,遇到变更时会抛出异常。 - TRY_EVOLVE 和 IGNORE:分别尝试应用变更或忽略变更。
需要注意的是,Hologres Sink 不支持 TRY_EVOLVE 策略,而其他目标端的支持情况需参考具体文档。
schema.change.behavior
来调整 Schema 变更的处理策略,确保目标端能够正确处理变更。希望以上信息能帮助您更好地理解 Flink CDC 3.0 对 SQL Server 和 Oracle Schema Change 的支持情况。如有进一步问题,请随时咨询!
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。