Flink是如何决定何时进行检查的

Question

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

Answer 1

首先，检查点协调器(作业管理器的一部分(使用检查点间隔来确定何时启动新的检查点。当您启用检查点时，就会通过此间隔，例如，在检查点之间等待10秒：

env.enableCheckpointing(10000L);

或者也可以通过CCD_ 1进行设置。

但是，无论需要多长时间，检查点协调器都将等待，以避免违反execution.checkpointing.max-concurrent-checkpoints或execution.checkpointing.min-pause的设置(定义从一个检查点完成到下一个检查点通始之间必须经过的时间(。