Flink---WaterMark機制

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

>>阅读原文<<