Flink更新於
Watermark 與遲到資料
事件時間、Watermark 策略及遲到事件的處理方法。
事件時間
事件時間是資料實際產生的時間,按事件時間計算才能得到正確的視窗結果。
Watermark 策略
大多數情況使用有界亂序策略即可,亂序上限按資料來源的實際延遲設定。
遲到資料
可以用 allowedLateness 延長視窗,或將遲到事件輸出到側輸出流另外處理。
2026 年第四季開發伺服器現接受預約。
查看方案事件時間、Watermark 策略及遲到事件的處理方法。
事件時間是資料實際產生的時間,按事件時間計算才能得到正確的視窗結果。
大多數情況使用有界亂序策略即可,亂序上限按資料來源的實際延遲設定。
可以用 allowedLateness 延長視窗,或將遲到事件輸出到側輸出流另外處理。