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

flink 15.3 cdc2.4 oracle 11g 开启这个参数就报这个错误?

flink 15.3 cdc2.4 oracle 11g 开启这个参数就报这个错误?image.png

展开
收起
真的很搞笑 2023-07-02 16:58:30 73 0
2 条回答
写回答
取消 提交回答
  • 从您提供的信息来看,您在使用 Flink CDC 2.4.0 连接 Oracle 11g 数据库时,启用了 Oracle 中的 DBMS_LOGMNR.SKIP_CORRUPTION 参数,但是出现了错误。

    根据您提供的错误截图,报错信息为 java.sql.SQLException: ORA-01305: fetched column value is NULL。这个问题可能与启用了 DBMS_LOGMNR.SKIP_CORRUPTION 参数有关。

    DBMS_LOGMNR.SKIP_CORRUPTION 参数会导致 Oracle 在读取日志时跳过某些错误或损坏的数据,这可能导致 Flink CDC 无法正确读取数据库中的数据。

    建议在使用 Flink CDC 2.4.0 连接 Oracle 11g 数据库时,不要启用 DBMS_LOGMNR.SKIP_CORRUPTION 参数。

    如果您已经启用了该参数并遇到以上错误,请尝试禁用该参数,并重新启动 Flink CDC 任务。如果问题仍然存在,您可以考虑升级 Oracle 数据库版本或更新 JDBC 驱动程序版本,以解决兼容性问题。

    另外,您还可以参考 Oracle 官方文档或社区讨论,了解如何正确配置和使用 DBMS_LOGMNR.SKIP_CORRUPTION 参数,以避免数据损坏或丢失的问题。

    2023-07-30 12:54:59
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    使用 Flink CDC 2.4.0 连接 Oracle 11g 数据库时,如果启用了 Oracle 11g 中的 DBMS_LOGMNR.SKIP_CORRUPTION 参数,可能会出现一些错误或者异常情况,例如:
    Copy
    java.sql.SQLException: ORA-01305: fetched column value is NULL
    这个问题是由于 Oracle 11g 中的 DBMS_LOGMNR.SKIP_CORRUPTION 参数会导致 Oracle 数据库在读取时跳过某些错误或者损坏的数据,从而导致 Flink CDC 无法正确读取数据库中的数据。因此,建议在使用 Flink CDC 2.4.0 连接 Oracle 11g 数据库时,不要启用 DBMS_LOGMNR.SKIP_CORRUPTION 参数。
    如果您已经启用了 DBMS_LOGMNR.SKIP_CORRUPTION 参数,并出现了以上错误或者异常情况,可以尝试关闭该参数,并重新启动 Flink CDC 任务。如果问题仍然存在,可以考虑升级 Oracle 数据库版本或者更新 JDBC 驱动程序版本,以避免出现类似的兼容性问题。同时,也可以参考 Oracle 官方文档或者社区讨论,了解如何正确配置和使用 DBMS_LOGMNR.SKIP_CORRUPTION 参数,以避免出现数据损坏或者丢失的问题。

    2023-07-30 10:15:40
    赞同 展开评论 打赏

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

相关产品

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

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

    相关镜像