Hi, tolerableCheckpointFailureNumber 限制的是最大可容忍的连续失败checkpoint计数 continuousFailureCounter [1],例如将tolerableCheckpointFailureNumber 设置成3,连续失败3次,continuousFailureCounter 会累计到3,作业就会尝试重启。 如果中间有一个checkpoint成功了,continuousFailureCounter 就会重置为零 [2]。
checkpoint失败后,如果作业没有发生failover,下一次checkpoint还是周期性的触发,并受 execution.checkpointing.min-pause [3] 等参数的影响。 [1] https://github.com/apache/flink/blob/4f5747fa0f7226c780742a4549408a38bc95d052/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java#L51 [2] https://github.com/apache/flink/blob/4f5747fa0f7226c780742a4549408a38bc95d052/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureManager.java#L161-L171 [3] https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/config.html#execution-checkpointing-min-pause 祝好 唐云 ________________________________ From: jiangjiguang719 <jiangjiguang...@163.com> Sent: Friday, January 29, 2021 9:35 To: user-zh@flink.apache.org <user-zh@flink.apache.org> Subject: 怎么理解 tolerableCheckpointFailureNumber tolerableCheckpointFailureNumber 是设置可容忍的checkpoint失败次数,具体怎么理解呢?比如 设置为3 1. 当checkpoint 失败时,该值+1,直到 大于 3,实时作业就发生失败或重启? 2. 当checkpoint 失败时,是立即进行下个checkpoint?还是根据周期设置自动触发? 3. 该值是累加值吗