Flink作业重启后，如何判断是否可以从checkpoint恢复

什么是从checkpoint恢复？

Flink Checkpoint 是一种容错恢复机制。这种机制保证了实时程序运行时，遇到异常或者机器问题时能够进行自我恢复。

从checkpoint恢复的原则

• 通常当作业执行失败、资源异常重启等非人为触发的异常场景时，支持从checkpoint恢复。
• 但是如果修改了作业的运算逻辑，作业的计算逻辑已发生更改，不支持从checkpoint恢复。

应用场景

本文列举了一些常见的从checkpoint恢复的场景供您参考，如表1所示。

更多场景可以使用从checkpoint恢复的原则结合实际情况进行判断。