为啥我的flink cdc oracle不设置'scan.startup.mode' = ?

为啥我的flink cdc oracle不设置'scan.startup.mode' = 'latest-offset'时读取不到原有表中的数据,设置了'scan.startup.mode' = 'latest-offset'可以读到最新的数据呢?select from t2; 有数据
select
from t3; 无数据

展开
收起
真的很搞笑 2023-08-22 17:58:36 413 分享 版权
1 条回答
写回答
取消 提交回答
  • Flink CDC 的 Oracle 连接器默认使用 INCREMENTAL 模式来扫描数据库。如果你不设置 scan.startup.mode 配置,那么 Flink CDC 会使用 INCREMENTAL 模式。

    你可以在配置文件中设置 scan.startup.mode 配置,来指定扫描模式。以下是可用的扫描模式:

    INCREMENTAL:从最新的 binlog 位置开始扫描数据库。
    FULL:扫描整个数据库。
    TABLE:扫描指定表的数据。
    你可以根据需要选择合适的扫描模式。

    以下是 Flink CDC 官方文档中关于扫描模式的介绍:

    2023-09-18 17:03:05
    赞同 展开评论

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

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