扫码关注公众号免费阅读全文:冰山烈焰的黑板报 原文地址:Flink Event Time Processing and Watermarks 如果你正在搭建一个实时流程序,事件时间处理是你不久将不得不使用的一个功能之一。因为在现实世界中绝大多数用例的消息都是乱序的,你的系统应该有一个方法应对和处理可能延迟的消息。在这篇博客中,我们将会看到为什么我们需要事件时间处理和我们怎么在 Flink 中
No Watermark (Watermarks are only available if EventTime is used) 问题背景 在 Flink 消费 kafka 的数据,经过一个 map 算子,然后调用 assignTimestampsAndWatermarks 生成 Watermark 后,然后 keyby + window,设置了 ContinuousEventTimeTri