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

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

>>阅读原文<<