Flink 1.10 版本之前如何生成 Watermark

Posted @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的主要内容,如果未能解决你的问题,请参考以下文章

Flink Batch SQL 1.10 实践

Flink处理函数实战之一:深入了解ProcessFunction的状态(Flink-1.10)

周一见 |GKE 推出 1.10 版本Containerd 集成进入 GA 阶段Flink 1.5 发布

Flink 1.11+ 版本如何生成 Watermark

Flink 1.11+ 版本如何生成 Watermark

Flink-1.10升级到Flink1.12的问题