flink滑动window会考虑重复消息吗？

Question

假设我正在使用事件时间处理并且滑动 windows 时间 window 10 和滑动因子 5 秒。

所以现在例如一些消息在 8 秒的事件时间到达所以它会首先落入

 window-1  1 to 10. 

现在它滑动了 5 秒，现在 window 是 5 到 15。所以 window1 考虑的相同消息，window2 也会考虑该消息。

  window2- 5 to 15

所以我的问题是，不是重复的消息会影响我的计算吗？ 建议我我在想好还是不好？ 如果它考虑了 bothe 消息，那么如何将其视为唯一？

Answer 1

记录被添加到所有与其时间戳重叠的滑动 windows，例如，在您的示例中，时间 8 的记录将被添加到 windows 1 to 10 和 5 to 15。