Flink學習筆記 --- WaterMark機制 and low WaterMark 保序機制

首先是張 Flink技術棧的圖： 然後然後解釋一下如何在高性能的情況下對數據進行保序操作處理： 如下圖所示： 當數據從kafka進入Flink中，數據有序，再經過map處理後，根據本地的時間生成 Window，然後啓動WaterMark機制，其中的時間叫做Ingestion Time， 從當前時間點開始產生WaterMark。 從當前時間點開始，後來的事件沒有比當前事件的EventTime更小的了

>>阅读原文<<