Flink---WaterMark機制

背景  使用Event time時間模型時，因爲網絡或傳輸等緣由，事件被Flink處理的順序不必定是事件產生的順序（亂序），可能會存在兩方面影響：html 當前窗口不知道什麼時候中止，開始計算結果； 影響窗口計算結果的準確性，見示例； WaterMark機制  WaterMark本質上是一個帶有時間戳的特殊event，當Flink中的運算符接收到水印時，它明白（假設）它不會看到比該時間戳更早的消息

>>阅读原文<<