Flink亂序數據處理過程解析

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