flink检查点如何帮助故障恢复

Question

1）以上假设是否正确。2）当发生故障时，滚动窗口有状态是否有意义，我们从最后一个kafka分区提交的偏移量开始。3）当滚动窗口有状态时，这个状态什么时候可以被flink使用。4）为什么检查点和保存点的状态大小不同。5）当发生故障时，flink总是从sorce运算符开始。对吗？

Answer 1

你的假设不正确。

（1）检查点不以任何方式依赖于到达接收器的事件或结果。

（2）Flink做自己的Kafaka偏置管理。当从检查点恢复时，在失败后，使用检查点中的偏移量，而不是那些可能已经提交回Kafka的偏移量。

（4）接收器利用屏障的到达刷新任何排队的输出，并提交挂起的事务。同样，这里有一些复杂性，因为事务接收器使用两阶段提交协议。

在应用程序中，如果检查点间隔比窗口持续时间小得多，那么接收器将在从窗口接收任何输出之前完成许多检查点。

（5）当检查点协调器从每个任务中听到检查点已完成时，它就完成检查点元数据。