为什么flink CDC 2.4.0读 oracle不打印呢?有遇到过的么?也不报错?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
Flink CDC 2.4.0 读取 Oracle 数据库时不打印数据,可能是因为 Flink CDC 2.4.0 默认使用了 Oracle LogMiner 连接器,该连接器在读取 Oracle 日志时默认使用了 skipOracleRedoLog 选项,该选项可以跳过一些不重要的日志。因此,如果您的 Oracle 数据库中没有产生符合要求的日志,Flink CDC 2.4.0 将不会输出任何数据。
为了解决这个问题,您可以尝试将 skipOracleRedoLog 选项设置为 false,以便 Flink CDC 2.4.0 读取所有的日志。以下是一个示例配置:
json
Copy
{
"name": "oracle-cdc",
"connector": {
"type": "oracle-cdc",
"hostname": "localhost",
"port": "1521",
"username": "user",
"password": "password",
"sid": "sid",
"table-name": "my_table",
"schema-name": "my_schema",
"parsing.interval": "1000",
"skipOracleRedoLog": "false"
}
}
在上面的示例配置中,我们将 skipOracleRedoLog 选项设置为 false,以便 Flink C
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。