当前位置:   article > 正文

flink检查点checkPoint算法_flink描述检查点算法过程

flink描述检查点算法过程

1、barrier是加入到数据流里面的一个标示(检查点分界线)。jobmanager发放checkpoint的指令给source,然后向下传递。

之前waterMark的算法是前面所有并行分区任务的waterMark都推进到当前的一个时间时(取最小的waterMark值),才往下推进任务。

barier也一样,当上游并行的所有的barier都到齐的时候,表示上游所有数据都处理完了,才可以进行保存,这就叫做barier对齐。

 2、事例:even偶数,odd奇数 

jobmanager在source1的偏移量3和source2的偏移量4后面插入barier 

将source1的偏移量3和source2的偏移量4存入checkPoint地址,source 将barier向下游广播 

只有source的蓝3黄4后面的bairier都到齐的时候才进行保存checkpoint操作,如果source的蓝3黄4后面的bairier还没到齐,但是后面的数据已经到了,不能进行计算,需要先进行缓存。

 

 

 

本文内容由网友自发贡献,转载请注明出处:【wpsshop博客】
推荐阅读
相关标签
  

闽ICP备14008679号