Flink Tumble Window 触发时间
Flink Tumble Window Trigger time
我正在使用 Flink 聚合来自 kafka 主题的数据。我正在使用 1 小时的翻滚 window，时间特征设置为事件时间。我还使用 AscendingTimestampExtractor 并根据 json 中的特定字段值将水印分配给输入。
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
我们可以假设用于加水印的JSON字段具有与系统时钟相似的时间值。
如果我在 3:25 下午部署作业，我什么时候可以期待 flink 聚合输出？会在 4:00 pm、5:00 pm ... 还是 3:25 pm -4:25 pm、4:25 pm -5 :25 pm....
Flink 的 windows 与 epoch（而不是第一个事件）对齐，因此如果作业部署在 3:25，第一个 window 大约是从3:00:00到3:59:59.999，之后会制作（根据水印）。
请注意，您可以将偏移量传递给构造函数，因此如果希望 windows 在整点过后 10 分钟结束，您可以通过指定
来实现
.window(TumblingEventTimeWindows.of(Time.hours(1), Time.minutes(10)))
我正在使用 Flink 聚合来自 kafka 主题的数据。我正在使用 1 小时的翻滚 window，时间特征设置为事件时间。我还使用 AscendingTimestampExtractor 并根据 json 中的特定字段值将水印分配给输入。
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
我们可以假设用于加水印的JSON字段具有与系统时钟相似的时间值。
如果我在 3:25 下午部署作业，我什么时候可以期待 flink 聚合输出？会在 4:00 pm、5:00 pm ... 还是 3:25 pm -4:25 pm、4:25 pm -5 :25 pm....
Flink 的 windows 与 epoch（而不是第一个事件）对齐，因此如果作业部署在 3:25，第一个 window 大约是从3:00:00到3:59:59.999，之后会制作（根据水印）。
请注意，您可以将偏移量传递给构造函数，因此如果希望 windows 在整点过后 10 分钟结束，您可以通过指定
来实现.window(TumblingEventTimeWindows.of(Time.hours(1), Time.minutes(10)))