Flink系列：事件Time時間亂序到達處理方法

  到達時間無序 kafka的數據，不一定按照時間產生的時間到達flink，爲了解決這個問題，需要引入Watermark   時間到達的3中情況 順序到達 亂序到達   併發到達   Watermark 如果指定多個Watermark，後面的將覆蓋前面的。 兩種方法   基於時間週期（推薦） 週期性（默認100ms）生成和發送Watermark，定義一個最大允許亂序時間。   基於特定事件 如果發

>>阅读原文<<