我正在使用Flink汇总来自kafka主题的数据。我正在使用1小时的滚动窗口，并将时间特征设置为“事件时间”。我还使用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汇总来自kafka主题的数据。我正在使用1小时的滚动窗口，并将时间特征设置为“事件时间”。我也在使用AscendingTimestampExtractor和...
Flink的窗口与纪元对齐（而不是第一个事件），因此，如果作业是在3:25部署的，则第一个窗口的间隔约为3:00:00到3：59：59.999，并且将在此后不久制作（基于水印）。