Re: 窗口时间不准

Sun, 07 Nov 2021 21:54:28 -0800 

Hi！

如果某个窗口里没有任何数据，那么这个窗口就不会产生。这个输出应该说明数据里没有 11:12:36 ~ 11:12:37 的内容。

陈卓宇 <2572805...@qq.com.invalid> 于2021年11月8日周一 上午11:24写道：

> 场景是:
> 首先使用assignTimestampsAndWatermarks定义了eventTime的时间语义,然后我调用window(TumblingEventTimeWindows.of(Time.seconds(1))).process(...)
> 开一个1秒钟的窗口进行逻辑的计算
> 在这个窗口内进行一个print控制台打印,打印的内容中通过context.window().getEnd()方法拿到窗口结束时间,发现有一部分
> 数据是大于1s的
> 数据:
> ==============&gt; 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)
> ==============&gt; 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)
> ==============&gt; 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的情况?
>
> 陈卓宇
>
>
> &nbsp;

回复