Flink如何处理早期活动?忽略或创建单独的窗口

Question

水印和后期事件处理很容易理解，但是早期事件呢？例如，如果原始流包含发生在3:00到4:00的事件，但是如果我将发生在6:00到7:00发生的一些事件插入流中，那么Flink如何处理它们？它将为他们创建单独的窗口，当窗口到期时，它们也会被处理？

Answer 1

根据水印策略，早期事件可以推进水印，然后导致随后的"按时"事件迟到。

Answer 2

早期事件未丢弃，而是放入相应的窗口中。当水印通过窗户的末端时间戳时，将处理窗口。因此，Flink能够同时维护多个窗口。