Flink 水位线：事件时间管理利器

Flink 水位线（Watermark）是一种机制，用于确定数据流中的事件时间（Event Time）进展到哪个时间点。它是由数据流中的事件时间戳（Event Timestamp）和延迟因素（Lateness）决定的。

水位线的作用是告诉 Flink 哪些事件时间已经到达，哪些事件时间还没有到达。水位线的生成由 Flink TaskManager 节点上的 Assigner 函数负责，一般情况下，Assigner 会将事件时间戳作为水位线。

当 Flink 任务处理数据时，会考虑水位线，只有当一个时间戳对应的水位线已经到达，才会触发窗口计算。这样可以避免因为数据延迟而导致的计算错误。同时，水位线还可以用来设置延迟时间，以容忍数据流中的延迟。