Flink:实时数据处理(8.容错机制)

文章目录 1.⼀致性检查点(checkpoint) 2.从检查点恢复状态 3.Flink 检查点算法(Chandy-Lamport算法) 3.1 ⼀种简单的想法(同步的思想) 3.2 Flink 的改进实现(异步的思想) 3.3 检查点分界线(Checkpoint Barrier,检查点屏障) 3.4 图示详解 4.保存点(save points) 1.⼀致性检查点(checkpoint) Fli
相关文章
相关标签/搜索