怎么理解 tolerableCheckpointFailureNumber tolerableCheckpointFailureNumber 是设置可容忍的checkpoint失败次数,具体怎么理解呢?比如 设置为3 1. 当checkpoint 失败时,该值+1,直到 大于 3,实时作业就发生失败或重启? 2. 当checkpoint 失败时,是立即进行下个checkpoint?还是根据周期设置自动触发? 3. 该值是累加值吗*来自志愿者整理的flink邮件归档
tolerableCheckpointFailureNumber 限制的是最大可容忍的连续失败checkpoint计数 continuousFailureCounter ,例如将tolerableCheckpointFailureNumber 设置成3,连续失败3次,continuousFailureCounter 会累计到3,作业就会尝试重启。 如果中间有一个checkpoint成功了,continuousFailureCounter 就会重置为零 。
checkpoint失败后,如果作业没有发生failover,下一次checkpoint还是周期性的触发,并受 execution.checkpointing.min-pause 等参数的影响。 *来自志愿者整理的flink邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。