说明
Savepoint 由 用户手动 创建,拥有和删除。
执行 savepoint,就是手动产生 Checkpoint,Savepoint 记录应用中所有算子的状态。
类比
checkpoint:相当于 word 自动保存
savepoint:相当于 word 手动保存
应用场景
适用于 有计划 的 手动备份 和 手动恢复
需要停止flink程序,然后再次运行的场景,如:
- 升级 Flink 版本
- 修改 flink 程序 bug
- 调整用户逻辑
- 改变并行度
操作完成后,再次启动 flink 程序,可以从 savepoint 恢复状态
与 checkpoint 区别
目的
- checkpoint:为意外失败的作业提供恢复机制
- savepoint:用户 有计划 的 执行、恢复
执行
- checkpoint:由 flink 自动执行
- savepoint:由 用户 手动执行
恢复
- checkpoint:因故障重启后,自动恢复
- savepoint:手动恢复
删除文件策略
- checkpoint:任务取消后,默认自动删除,可配置成不删除
- savepoint:需手动删除