Flink两次checkpoint最小间隔时间如何计算
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
最小间隔时间是按照上次成功的checkpoint开始计算PS:
配置间隔时间为3s,最小间隔时间为5s,这种情况下,间隔时间会调整为5s 即: execution.checkpointing.interval配置为3s,execution.checkpointing.min-pause配置为5s。 以两个场景进行说明,两个场景checkpoint间隔时间为3分钟,超时时间为10分钟,最小间隔时间为5分钟。
● 场景一:作业正常运行(checkpoint每次都成功)12:00第一次开始执行checkpoint,12:00:02 checkpoint 成功,第二次checkpoint开始时间为12:05:02。
● 场景二:作业不正常(checkpoint因某些原因超时或者失败,本次场景以超时为例)12:00第一次开始执行checkpoint,12:00:02 checkpoint 成功-->>12:05:02第二次开始执行checkpoint,12:15:02超时失败,第三次checkpoint开始时间为12:15:02。