Flink作业重启时MySQL CDC源表会从作业停止时的位置消费吗
已解决Flink作业重启时MySQL CDC源表会从作业停止时的位置消费吗
展开
收起
1
条回答
写回答
写回答
-
开发者社区问答官方账号官方回答采纳回答Flink作业重启时，可以自由选择启动策略。如果选择全新启动，MySQL CDC源表会从配置的位置重新消费。如果选择从最新状态恢复，MySQL CDC源表会从作业停止时的位置开始消费。比如，作业配置为从Binlog位点{file=mysql-bin.01，position=40}启动作业，作业运行一段时间后停止，此时消费到Binlog位点{file=mysql-bin.01，position=210}。如果选择全新启动，MySQL CDC源表会重新从Binlog位点{file=mysql-bin.01，position=40}消费。如果选择从最新状态恢复，则会从Binlog位点{file=mysql-bin.01，position=210}开始消费。注意作业重启时，保证所需Binlog在服务器上没有因过期被清理，否则会报错。2024-05-31 15:03:24赞同 展开评论 打赏
关联地址：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
