flink乱序流水位线

Flink处理乱序流时，通过水位线（Watermark）来确定事件时间窗口的边界。水位线是由WatermarkGenerator生成的，它根据事件的时间戳生成水位线。在乱序流中，水位线的时间戳实际上是当前最大时间戳减去延迟时间减去1毫秒。这是因为水位线的特点是，时间戳为t的水位线表示时间戳小于等于t的数据已经全部到达，不会再有新的数据到来。如果考虑有序流，即延迟时间为0的情况，当时间戳为7秒的数据到达时，之后仍然有可能继续到达7秒的数据，因此生成的水位线不是7秒，而是6秒999毫秒，以便继续接收7秒的数据。\[3\]
#### 引用[.reference_title]
- *1* [Flink流计算编程--watermark（水位线）简介](https://blog.csdn.net/lmalds/article/details/52704170)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insertT0,239^v3^insert_chatgpt"}} ] [.reference_item]
- *2* *3* [Flink水位线](https://blog.csdn.net/qq_51235856/article/details/129012722)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insertT0,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]