Flink 1.10 版本之前如何生成 Watermark

Posted 2022-08-30 @SmartSi

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink 1.10 版本之前如何生成 Watermark相关的知识，希望对你有一定的参考价值。

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

Flink 1.10

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

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

以上是关于Flink 1.10 版本之前如何生成 Watermark的主要内容，如果未能解决你的问题，请参考以下文章