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 <
[hidden email]>
Sent: Friday, January 29, 2021 9:35
To:
[hidden email] <
[hidden email]>
Subject: 怎么理解 tolerableCheckpointFailureNumber
tolerableCheckpointFailureNumber 是设置可容忍的checkpoint失败次数,具体怎么理解呢?比如 设置为3
1. 当checkpoint 失败时,该值+1,直到 大于 3,实时作业就发生失败或重启?
2. 当checkpoint 失败时,是立即进行下个checkpoint?还是根据周期设置自动触发?
3. 该值是累加值吗