Flink CDC 里 oracle-cdc 从oracle源捞实时数据, 不定期会报这个错误,怎么解决?
参考
https://github.com/apache/flink-cdc/pull/2315
另外已经修好了,等下一个发布包。 此回答来自钉群Flink CDC 社区。
确认从Oracle数据库同步出来的数据流中的字段是否正确映射到目标表结构。如果目标表中没有名为“file”的字段,则需要在Flink CDC的表映射配置中排除或重命名该字段。
在Flink CDC Oracle Connector的配置中,确保配置了正确的列白名单或黑名单以过滤掉不需要或者不合法的字段。
如果Oracle源库表结构发生过变更,可能引入了新的字段“file”而目标表未及时更新,这时需要调整目标表结构以匹配源表。
检查Oracle CDC Connector的日志解析逻辑是否出现了误判,比如捕获了不应该捕获的数据片段作为字段名。
确认使用的Flink和Flink CDC Oracle Connector版本是否有已知的问题,如有,尝试升级至最新稳定版,并查看官方文档或社区是否有针对类似问题的解决方案或补丁。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。