请问一下 flink cdc mysql 2.2.1

image.png 不支持从binlog指定位置重启吗?

展开
收起
雪哥哥 2022-10-29 23:42:49 317 发布于浙江 分享
分享
版权
举报
阿里云 AI 助理回答

不支持同时开启scan.binlog.newly-added-table.enabledscan.newly-added-table.enabled配置项,这与直接从Binlog指定位置重启作业的询问不直接相关。但是,关于从特定Binlog位点启动,Flink在订阅Binlog时确实提供了这样的能力。您可以通过设置以下参数来实现从指定Binlog位置启动:

  • scan.startup.mode 设置为 specific-offset
  • 配置 scan.startup.specific-offset.file 为启动位点的Binlog文件名。
  • 配置 scan.startup.specific-offset.pos 为启动位点的Binlog文件位置。

这样可以在作业启动时,从您指定的Binlog文件和位置开始读取数据,而非默认的全量数据扫描或最新Binlog位置。

另外,文档中提到DTS服务当前暂不支持指定位点启动的功能,但此信息针对的是DTS服务,而非直接操作Flink或MySQL Binlog时的场景。

综上所述,直接通过Flink配置是可以实现从Binlog指定位置重启作业的,但需注意具体配置细节与限制。

有帮助
无帮助
AI 助理回答生成答案可能存在不准确,仅供参考
0 条回答
写回答
取消 提交回答

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

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等