天天看點

flink -watermark

Watermark

1、Flink處理亂序資料的手段,設定事件時間戳,作為判斷标準。

2、設定延遲發車時間,等待未到的資料一段時間。

3、有周期水位線和打點水位線。

4、多路并發的時候,取所有分區水位線最小的作為标準。集合合并也是取最小的水位線。

繼續閱讀