什么是Checkpoint

如果Flink运行时，某个算子出现故障，如何处理？

当故障恢复后，又如何保证数据状态和恢复前保持一致？

Flink通过Checkpoint机制，为程序生成快照（Snapshot），如果程序崩溃，那么就可以有选择地从这些快照中进行恢复。