Flink 1.10 版本之前如何生成 Watermark

传送门：Flink 系统性学习笔记

---

Flink 1.9

我们说使用 Watermark，那我们是在基于事件时间处理数据，首先第一步就是设置时间特性：

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.
1