flink 15.3 cdc2.4 oracle 11g 开启这个参数就报这个错误?
从您提供的信息来看,您在使用 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
参数,以避免数据损坏或丢失的问题。
使用 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 参数,以避免出现数据损坏或者丢失的问题。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。