flink1.12.x Savepoint(与 checkpoint 的区别)

说明

Savepoint 由 用户手动 创建,拥有和删除。

执行 savepoint,就是手动产生 Checkpoint,Savepoint 记录应用中所有算子的状态。

类比

checkpoint:相当于 word 自动保存

savepoint:相当于 word 手动保存

应用场景

适用于 有计划手动备份手动恢复

需要停止flink程序,然后再次运行的场景,如:

  • 升级 Flink 版本
  • 修改 flink 程序 bug
  • 调整用户逻辑
  • 改变并行度

操作完成后,再次启动 flink 程序,可以从 savepoint 恢复状态

与 checkpoint 区别

目的

  • checkpoint:为意外失败的作业提供恢复机制
  • savepoint:用户 有计划 的 执行、恢复

执行

  • checkpoint:由 flink 自动执行
  • savepoint:由 用户 手动执行

恢复

  • checkpoint:因故障重启后,自动恢复
  • savepoint:手动恢复

删除文件策略

  • checkpoint:任务取消后,默认自动删除,可配置成不删除
  • savepoint:需手动删除

原文出处:https://malaoshi.top/show_1IX49bn2usWH.html