清除数据流中的Flink水印状态

Question

是否可以清除数据流中的当前水印？

一个月长的水印不允许延迟的示例输入：

[
  { timestamp: '10/2018' },
  { timestamp: '11/2018' },
  { timestamp: '11/2018', clearState: true },
  { timestamp: '9/2018' }
]

通常，“2018年9月”的记录会因为时间太晚而被扔掉。当看到clearState消息时，是否有方法以编程方式重置水印状态？

Answer 1

水印不应该倒退——它不确定会发生什么，实际上这是个坏主意。然而，有各种方法来容纳迟交的数据。

如果您正在使用窗口API，Flink将在窗口的允许延迟过期后清除任何窗口状态。如果您想要更多的控制，请考虑使用<代码>处理函数< /> >，这将允许/要求您显式地管理状态（和定时器）。