开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

为啥我的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 283 0
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 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    PostgresChina2018_樊文凯_ORACLE数据库和应用异构迁移最佳实践 立即下载
    PostgresChina2018_王帅_从Oracle到PostgreSQL的数据迁移 立即下载
    Oracle云上最佳实践 立即下载

    相关镜像