[Flink原理介绍第四篇】:Flink的Checkpoint和Savepoint介绍

第一部分:Flink的Checkpoint 1. Flink Checkpoint原理介绍 Checkpoint是Flink实现容错机制最核心的功能,它可以根据配置周期性地基于Stream中各个Operator的状态来生成Snapshot,从而将这些状态数据按期持久化存储下来,当Flink程序一旦意外崩溃时,从新运行程序时能够有选择地从这些Snapshot进行恢复,从而修正由于故障带来的程序数据状
相关文章
相关标签/搜索