天天看点

flink -watermark

Watermark

1、Flink处理乱序数据的手段,设定事件时间戳,作为判断标准。

2、设定延迟发车时间,等待未到的数据一段时间。

3、有周期水位线和打点水位线。

4、多路并发的时候,取所有分区水位线最小的作为标准。集合合并也是取最小的水位线。

继续阅读