| 作用 | 界定窗口何时可以触发计算 |
|---|---|
| 生成 | 事件时间字段减去固定延迟，也可自定义 |
| 单调性 | 水位线只增不减，迟到数据不改变已发出的水位线 |
Flink SQL 声明水位线
Flink SQL 声明水位线
WATERMARK FOR ts AS ts - INTERVAL '10' SECOND -- 容忍 10 秒乱序迟到数据的两种处理
迟到数据的两种处理
1) 允许窗口多等待：加大水位线延迟
2) 丢弃但旁路输出：迟到数据写侧输出流单独分析水位线延迟调大意味着窗口保持更久、状态更大；要在结果准确性与恢复成本之间取值。