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

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

>>阅读原文<<