Flink 如何决定何时采取检查点？

Question

我想了解什么决定了何时采取检查点。这与检查点间隔有何关系？

Answer 1

初步估计，检查点协调器（作业管理器的一部分）使用检查点间隔来确定何时启动新检查点。当您启用检查点时，会经过此间隔，例如，这里设置检查点之间等待 10 秒：

env.enableCheckpointing(10000L);

或者也可以通过设置execution.checkpointing.interval。

execution.checkpointing.max-concurrent-checkpoints然而，检查点协调器将等待必要的时间，以避免违反 for或 for 的设置execution.checkpointing.min-pause（定义一个检查点完成与下一个检查点开始之间必须经过多长时间）。