Re: Some doubts about window start time and end time

Posted by zhangjun on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Some-doubts-about-window-start-time-and-end-time-tp31272p31274.html

Hi，Caizhi ：

the code like this :

dataStream

.keyBy(“device")

.window(TumblingProcessingTimeWindows.of(Time.hours(6)))

.trigger(ContinuousProcessingTimeTrigger.of(Time.seconds(5)))

                                .aggregate(new MyAggre(), new WindowResultFunction())  

                                 .print();

I add a trigger for quick output

On 11/27/2019 17:54，[hidden email] wrote：

Hi Jun,

How do you define your window? Could you please show us the code?

Thanks.

Jun Zhang <[hidden email]> 于2019年11月27日周三 下午5:22写道：

,

Hi:

I defined a Tumbling window, I set the time size to one hour, and the resulting windows are [00: 00: 00-01: 00: 00], [01: 00: 00-02: 00: 00]. ....

This meets my expectations, but when I set the time size to 6 hours, the resulting window size is [02: 00: 00-08: 00: 00], [08: 00: 00-14: 00: 00], [14: 00: 00-20: 00: 00] ...

But my expected window size is [00: 00: 00-06: 00: 00], [06: 00: 00-12: 00: 00] ...

Is it right to get such a window result?

thanks