Flink 启用与配置检查点 Checkpoint

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

---

Flink版本：1.11

Flink 中每个函数和算子都可以是有状态的（请参阅状态分类了解详细信息）。有状态函数在处理单个元素/事件时会存储数据。为了能够使状态可以容错，Flink 需要对状态进行 Checkpoint。Checkpoint 可以允许 Flink 在流中恢复状态以及消费位置。

关于 Flink 容错机制背后的技术请参阅流式容错的详细文档。

1. 前提条件<