ApacheFlink-基于事件时间计算最后一个窗口

Question

我的工作是做以下事情：

1. 根据事件时间使用Kafka主题中的事件
2. 计算7天的窗口大小，以1天的幻灯片显示
3. 将结果放入Redis

我有几个问题：

1. 如果它从最近的记录中消耗Kafka事件，在作业存活1天后，作业关闭窗口并计算7天窗口。问题是作业只有1天的数据，因此结果是错误的。
2. 如果我尝试让它从7天前的时间戳中消耗Kafka事件，当作业开始时，它从第一天开始计算整个窗口，并且花费了很多时间。另外，我只想要最后一个窗口的结果，因为这对我来说很重要。

我错过什么了吗？有更好的方法吗？

Answer 1

Flink将时间窗口与时代对齐。因此，如果你有一个小时长的窗口，它们从一个小时的顶端运行到另一个小时的顶端。白天的窗户从午夜开到午夜。同样的原则也适用于七天长的窗户，因为新纪元开始于周四（1970年1月1日），七天长的窗户应该在周三晚上/周四早上的午夜关闭。

如果要将窗口移到其他时间启动，可以向窗口构造函数提供偏移量。