开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC 里 oracle-cdc 从oracle源捞实时数据 不定期会报这个错误怎么办?

Flink CDC 里 oracle-cdc 从oracle源捞实时数据, 不定期会报这个错误,怎么解决?5c003ebd2e4cf2a565ff08544e3a5f22.png

展开
收起
小小鹿鹿鹿 2024-03-20 08:01:40 30 0
2 条回答
写回答
取消 提交回答
  • 参考
    https://github.com/apache/flink-cdc/pull/2315
    另外已经修好了,等下一个发布包。 此回答来自钉群Flink CDC 社区。

    2024-03-20 11:23:08
    赞同 1 展开评论 打赏
    • 检查表结构与配置:

    确认从Oracle数据库同步出来的数据流中的字段是否正确映射到目标表结构。如果目标表中没有名为“file”的字段,则需要在Flink CDC的表映射配置中排除或重命名该字段。

    • 过滤无效字段:

    在Flink CDC Oracle Connector的配置中,确保配置了正确的列白名单或黑名单以过滤掉不需要或者不合法的字段。

    • 检查源库表变更:

    如果Oracle源库表结构发生过变更,可能引入了新的字段“file”而目标表未及时更新,这时需要调整目标表结构以匹配源表。

    • 排查日志解析异常:

    检查Oracle CDC Connector的日志解析逻辑是否出现了误判,比如捕获了不应该捕获的数据片段作为字段名。

    • 升级或修复Connector:

    确认使用的Flink和Flink CDC Oracle Connector版本是否有已知的问题,如有,尝试升级至最新稳定版,并查看官方文档或社区是否有针对类似问题的解决方案或补丁。

    2024-03-20 09:37:28
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载

    相关镜像