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??Caizhi Weng<tsreape...@gmail.com> wrote?? Hi Jun, How do you define your window? Could you please show us the code? Thanks. Jun Zhang <825875...@qq.com> ??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