Flink笔记-延迟数据处理

Flink的窗口处理流式数据虽然提供了基础EventTime的WaterMark机制,但是只能在一定程度上解决数据乱序问题。而某些极端情况下数据延迟会非常严重,即便通过WaterMark机制也无法等到数据全部进入窗口再进行处理。...

admin 2020-04-13 16:48:35

Flink 窗口滚动和滑动操作

Flink 窗口滚动和滑动操作...

user 2020-04-15 09:57:00