2026 年第四季開發伺服器現接受預約。

Thread Sync Zone
Flink更新於

Watermark 與遲到資料

事件時間、Watermark 策略及遲到事件的處理方法。

事件時間

事件時間是資料實際產生的時間,按事件時間計算才能得到正確的視窗結果。

Watermark 策略

大多數情況使用有界亂序策略即可,亂序上限按資料來源的實際延遲設定。

遲到資料

可以用 allowedLateness 延長視窗,或將遲到事件輸出到側輸出流另外處理。