如何理解Flink中的SavePoints机制

2020-08-03 10:08发布

1条回答
记忆里的东关
2020-08-03 10:13

SavePoints是检查点的一种特殊实现,底层其实也是使用CheckPoints的机制,SavePoints是用户以手工命令的方式触发CheckPoint,并将结果持久化到指定的存储路径中,其主要目的就是帮助用户在升级和维护集群过程中保存系统中的状态数据,避免因为停机运维或者升级应用等正常终止应用的操作而导致系统无法恢复到原有的计算状态的情况,从而无法实现端到端的exactly-once语义保证。

一周热门 更多>