流式管道使用跳跃窗口，但一些延迟到达的数据未被视为延迟数据，导致聚合不正确。如何将延迟数据捕获到正确的窗口中？

正确答案是使用水印（watermarks）定义预期的数据到达窗口，并允许延迟数据在到达时处理。水印是流处理中用于衡量事件时间进度的机制。当数据晚于其对应窗口的水印到达时，它被认为是延迟数据。通过配置流处理系统以允许延迟数据（例如，通过设置允许的延迟时间），即使数据到达较晚，也可以将其分配到正确的窗口中进行处理，从而纠正聚合。 将窗口函数更改为翻滚窗口（tumble windows）或会话窗口（session windows）不能解决延迟数据的问题。翻滚窗口是固定大小、不重叠的窗口，会话窗口是根据活动间隔动态定义的，两者本身都不处理延迟数据。扩展跳跃窗口（hopping windows）可能会减少一些数据被视为延迟数据的情况，但不能保证所有延迟数据都能被捕获到正确的窗口中，并且会增加窗口的复杂性和资源消耗，不是根本的解决方案。