![图片[1] - 大数据_Flink_Java版_状态一致性(2)-端到端状态一致性—Flink工作笔记0077 - MaxSSL](https://www.maxssl.com/uploads/?url=https://www.maxssl.com/uploads/?url=https://img-blog.csdnimg.cn/8a4e5aa0364f48a4a88bd09590eba2cb.png)
然后我们来看,一致性检查点,可以看到,
一致性检查点,是flink故障恢复机制的核心,可以记录所有算子的状态,并且只记录一次,
精确恢复一次对吧.
![图片[2] - 大数据_Flink_Java版_状态一致性(2)-端到端状态一致性—Flink工作笔记0077 - MaxSSL](https://www.maxssl.com/uploads/?url=https://www.maxssl.com/uploads/?url=https://img-blog.csdnimg.cn/b7d2c6679dd740eeb9a3ef2b85460193.png)
我们可以看看,sum_even,这里的6 2+4 sum_odd这里的9 1+3+5可以看到
现在是,5这个数据处理完了,就把所有的状态都记录了.把5这个数据处理完以后,
所有的节点状态在jobmanager记录了可以看到,5,6,9都记录了,恢复的时候用
![图片[3] - 大数据_Flink_Java版_状态一致性(2)-端到端状态一致性—Flink工作笔记0077 - MaxSSL](https://www.maxssl.com/uploads/?url=https://www.maxssl.com/uploads/?url=https://img-blog.csdnimg.cn/cd0fbedcab7d48a0943b21a483b16a3c.png)
</
© 版权声明
文章版权归作者所有，未经允许请勿转载。
THE END
喜欢就支持一下吧
然后我们来看,一致性检查点,可以看到,
一致性检查点,是flink故障恢复机制的核心,可以记录所有算子的状态,并且只记录一次,
精确恢复一次对吧.
我们可以看看,sum_even,这里的6 2+4 sum_odd这里的9 1+3+5可以看到
现在是,5这个数据处理完了,就把所有的状态都记录了.把5这个数据处理完以后,
所有的节点状态在jobmanager记录了可以看到,5,6,9都记录了,恢复的时候用
</
