赞
踩
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还没到齐,但是后面的数据已经到了,不能进行计算,需要先进行缓存。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。