Flink 利用 Checkpoint 实现故障恢复

传送门：Flink 系统性学习笔记

---

Flink 1.13.5 版本

在本节中，我们将介绍 Flink 如何利用检查点 Checkpoint 实现故障恢复。

1. 配置

如果我们的任务已经执行很长时间，突然遇到故障停止，那么中间过程处理结果就会全部丢失，重启后如果需要重新从上线开始的位置消费，那么会花费我们很长的时间。这种结局显示我们不能接受，我们希望的是作业在故障失败重启后能保留之前的状态并能从失败的位置继续消费。这就需要 Flink 利用检查点 Checkpoint 实现故障恢复并保证精确一次 Exactly-Once 语义的一致性状态。可以通过如下配置设置 Checkpoint：

final StreamExecutionEnvironment env = StreamExecutionEnvironment.