Flink学习笔记 --- WaterMark机制 and low WaterMark 保序机制

首先是张 Flink技术栈的图： 然后然后解释一下如何在高性能的情况下对数据进行保序操作处理： 如下图所示： 当数据从kafka进入Flink中，数据有序，再经过map处理后，根据本地的时间生成 Window，然后启动WaterMark机制，其中的时间叫做Ingestion Time， 从当前时间点开始产生WaterMark。 从当前时间点开始，后来的事件没有比当前事件的EventTime更小的了

>>阅读原文<<