网站介绍：文章浏览阅读608次。优化方案：Flink允许跳过对齐这一步，或者说一个算子子任务不需要等待所有上游通道的Checkpoint Barrier，直接将Checkpoint Barrier广播，执行快照并继续处理后续流入的数据。为了保证数据一致性，Flink必须将那些较慢的数据流中的元素也一起快照，一旦重启，这些元素会被重新处理一遍。周期性地生成 Watermark 的生成，默认是 200ms。（1）每次进行Checkpoint前，都需要暂停处理新流入数据，然后开始执行快照，假如状态比较大，一次快照可能长达几秒甚至几分钟。
- 链接地址：https://blog.csdn.net/MyNameIsWangYi/article/details/126460605
- 链接标题：【精选】flink篇——Time和watermark机制_王一1995的博客-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：9161
- 网站标签：flink篇——Time和watermark机制
