为什么flink CDC 2.4.0读 oracle不打印呢?有遇到过的么?也不报错?

为什么flink CDC 2.4.0读 oracle不打印呢?有遇到过的么?也不报错?

展开
收起
十一0204 2023-07-19 17:09:50 169 分享 版权
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    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

    2023-07-29 20:27:42
    赞同 展开评论

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

还有其他疑问?
咨询AI助理