窗口时间不准

场景是: 首先使用assignTimestampsAndWatermarks定义了eventTime的时间语义,然后我调用window(TumblingEventTimeWindows.of(Time.seconds(1))).process(...) 开一个1秒钟的窗口进行逻辑的计算 在这个窗口内进行一个print控制台打印,打印的内容中通过context.window().getEnd()方法拿到窗口结束时间,发现有一部分 数据是大于1s的 数据: ==============> ResultBean(key=ZYSZ000001, count=2, timestamp=1636341155000, datetime=2021-11-08 11:12:35, indicator=elevator.analysis.sum.floor, userablerate=null, sumofflinetime=null, forusetime=null, producttime=null) ==============> ResultBean(key=ZYSZ000001, count=3, timestamp=1636341158000, datetime=2021-11-08 11:12:38, indicator=elevator.analysis.sum.floor, userablerate=null, sumofflinetime=null, forusetime=null, producttime=null) ==============> ResultBean(key=ZYSZ000001, count=5, timestamp=1636341159000, datetime=2021-11-08 11:12:39, indicator=elevator.analysis.sum.floor, userablerate=null, sumofflinetime=null, forusetime=null, producttime=null)

问题: 为什么名名我设置了1s的窗口,还会会出现时间大于1s的情况? *来自志愿者整理的flink邮件归档