当我们使用实时数据流进行基于事件时间的聚合时，具有特定密钥的事件的水印是否会触发其他密钥在windows上的窗口操作？
e、 在10分钟的事件时间窗口上聚合。收到以下事件序列：
id 1 at 12:00
id 1 at 12:08
id 2 at 12:15
id 1 at 12:20id为2的事件将在id为1的12:00-12:10的时间窗口内发生吗？或者它只会在12:20发生，当下一个id为1的事件到达时？
当我们使用实时数据流进行基于事件时间的聚合时，具有特定密钥的事件的水印是否会触发其他密钥在windows上的窗口操作？
e、 在10分钟的事件时间窗口上聚合。收到以下事件序列：
id 1 at 12:00
id 1 at 12:08
id 2 at 12:15
id 1 at 12:20id为2的事件将在id为1的12:00-12:10的时间窗口内发生吗？或者它只会在12:20发生，当下一个id为1的事件到达时？
1条答案
按热度按时间kcwpcxri1#
水印与密钥没有关联--它们是每个流的，或者在kafka的情况下，它们可以是每个kafka分区的--所以是的，基于一个密钥的事件生成的水印也会触发其他密钥的窗口。
每密钥水印是flink社区已经讨论过的事情，也许有一天会发生，但从Flink1.5开始，就是这样。