06-Flink的容错机制

目录 一致性检查点(checkpoint) 从检查点恢复状态 Flink检查点算法 保存点(save points) 一致性检查点(checkpoint) (1) flink故障恢复机制的核心,就是应用状态的一致性检查点 (2) 有状态流应用的一直检查点,其实就是所有任务的状态,在某个时间点的一份拷贝(一份快照);这个时间点,应该是所有任务都恰好处理完一个相同的输入数据的时候 从检查点恢复状态 (
相关文章
相关标签/搜索