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还没到齐，但是后面的数据已经到了，不能进行计算，需要先进行缓存。
