FlinkFlink 1.14 版本 新特性 Barrier 在流经算子做 checkpoint Barrier跳过 unaligned checkpoint

Posted 2021-09-03 九师兄

1.概述

在博客 【Flink】FLink Barrier 在流经算子 做 checkpoint 的时候，数据是停止的吗？ 中，我们知道。

barrier之前的算子还会处理数据，barrier对其的时候，这个节点是不处理数据的，只是缓存数据，真正barrier的时候会停止处理数据，但是这个时间很短。

但是在新特性中，使用了新的方案，此时我想的是 你妹呀，我刚刚学会这种，然后你就又变化了。

在 Apache Flink Meetup 深圳站的视频中。参考：

这个视频中。

2. 目前状态

2.1 无限流