Flink亂序數據處理過程解析

流數據流經source，再到operator，由於網絡延遲等原因，導致亂序的產生（這裏的亂序是指事件產生的時間EventTime和到達處理機制進行處理的順序不一樣），特別是使用kafka的話，多個分區的數據source之後無法保證有序。所以在進行window計算的時候，如果有涉及時間的，比如（前一小時的訪問量），必須要有個機制來保證操作結果的相對準確性。Flink運用一下幾個機制來保證事件事件和操

>>阅读原文<<