=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 从您提供的信息来看,您在使用 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 参数,以避免数据损坏或丢失的问题。

  2. 使用 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 参数,以避免出现数据损坏或者丢失的问题。