Flink CDC里有没有同学知道这个问题是不是在最新版本里被解决了?
https://github.com/apache/flink-cdc/issues/732
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
根据您提供的问题链接(https://github.com/apache/flink-cdc/issues/732),该问题涉及Flink CDC在处理某些场景时的兼容性或功能缺陷。虽然知识库中并未直接提及该GitHub Issue的具体内容,但我们可以结合实时计算Flink版的更新日志和修复记录来判断是否已在最新版本中解决。
Flink CDC相关更新:
op_type
虚拟列、优化Decimal类型主键表读取性能、支持Source复用功能等。缺陷修复:
GitHub Issue背景:
结合上述信息,可以得出以下结论: - 如果该问题属于功能增强类(如新增op_type
虚拟列或Source复用功能),则已在最新版本中通过功能优化解决。 - 如果该问题属于性能优化类(如Decimal类型主键表读取性能或SourceRecord并行处理),则已在VVR 8.0.7版本中得到提升。 - 如果该问题属于缺陷修复类(如数据丢失或状态不一致),则可能已在VVR 8.0.7或更早版本中修复。
为了确认该问题是否已解决,您可以采取以下步骤: 1. 升级到最新版本: - 确保您的作业引擎已升级至VVR 8.0.7或更高版本。具体操作请参见[作业引擎版本升级]文档。 2. 验证问题场景: - 在升级后重新运行相关作业,观察是否仍存在原问题。 3. 查阅官方文档: - 查看实时计算Flink版的[更新日志]和[Flink CDC连接器文档],确认是否有针对该问题的明确说明。 4. 联系技术支持: - 如果问题仍未解决,建议联系阿里云技术支持团队,提供详细的错误日志和复现步骤,以便进一步排查。
根据现有资料,Flink CDC在最新版本中进行了多项功能增强和缺陷修复,可能已解决您提到的问题。建议您升级到最新版本并验证问题场景。如果仍有疑问,请提供更多具体信息以便进一步分析。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。