Flink Checkpoint Checkpoint 是 Flink 实现容错机制最核心的功能，它能够根据配置周期性地基于 Stream 中各个 Operator 的状态来生成 Snapshot，从而将这些状态数据定期持久化存储下来，当 Flink 程序一旦意外崩溃时，重新运行程序时可以有选择地从这些 Snapshot 进行恢复，从而修正因为故障带来的程序数据状态中断。这里，我们简单理解一下 Flink Checkpoin t机制，如官网下图所示： Checkpoint 指定触发生成时间间隔后，每当需要触发 Checkpoint 时，会向 Flink 程序运行时的多个分布式的 Stream Source 中插入一个 Barrier 标记，这些 Barrier 会根据 Stream 中的数据记录一起流向下游的各个 Operator。当一个 Operator 接收到一个 Barrier 时，它会暂停处理 Steam 中新接收到的数据记录。因为一个 Operator 可能存在多个输入的 Stream，而每个 Stream 中都会存在对应的 Barrier，该 Operator 要等到所有的输入 Stream 中的 Barrier 都到达。当所有 Stream 中的 Barrier 都已经到达该 Operator，这时所有的 Barrier 在时间上看来是同一个时刻点（表示已经对齐）