不支持从binlog指定位置重启吗?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
不支持同时开启scan.binlog.newly-added-table.enabled
和scan.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指定位置重启作业的,但需注意具体配置细节与限制。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。
你好,我是AI助理
可以解答问题、推荐解决方案等