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

Flink CDC不需要指定 在特定位点启动模式下指定 GTID 集合 么?

"Flink CDC不需要指定 'scan.startup.specific-offset.gtid-set' = '24DA167-0C0C-11E8-8442-00059A3C7B00:1-19', -- 在特定位点启动模式下指定 GTID 集合 么?image.png
"

展开
收起
真的很搞笑 2023-11-01 14:11:51 119 0
2 条回答
写回答
取消 提交回答
  • 问题1: 是的,Flink CDC在启动时需要指定'scan.startup.mode'为'specific-offset',并设置'scan.startup.specific-offset.file'和'scan.startup.specific-offset.pos'来指定binlog文件名和位置。

    问题2: 是的,你可以将上述组合方式用于从特定位点启动Flink CDC。

    2023-11-02 15:16:46
    赞同 展开评论 打赏
  • "只能用一种方式启动,保证从检查点启动也需要和初始的时候保持一致,你用a方式启动,保存了检查点b。你从检查点b启动还必须要用a启动方式,检查点前后的启动方式要保持一致,如果一致的情况下,你这个错误,很明显就是找不到binlog点位导致的问题image.png
    image.png
    image.png
    你可以找到这个009913结尾的binlog文件吗,此回答整理自钉群“Flink CDC 社区”"

    2023-11-01 21:24:39
    赞同 展开评论 打赏

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

相关产品

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

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载