Flink学习笔记(十七)：探讨Flink的重启策略

简介：
本篇博客为《Flink学习笔记》系列文章第十七篇，主要探讨了Apache Flink的重启策略，帮助读者深入了解如何配置和优化Flink任务在故障发生时的自动恢复机制。 ### 1. 引言 在讨论 Flink 的重启策略之前，首先需要了解 State、StateBackend 和 CheckPointing 这三个核心概念。 ### 1.1 状态（State） Flink 实时计算程序为了确保在出现异常情况时能够进行容错处理，会将中间的计算结果数据存储起来。这种保存下来的中间数据被称为状态（State）。默认情况下，状态会被保留在 JobManager 的内存中；不过也可以选择将其存放在本地文件系统或 HDFS 等分布式文件系统里。 ### 1.2 存储后端（StateBackend） 用于管理并持久化这些状态信息的组件称为存储后端（StateBackend）。