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