Dear All, I have a question about the Window Trigger: let’s say i would like like use the SlidingEventTimeWindow (60 seconds window size + 1 second window shift) to count the number of records per window. And I am using Event Time with periodic watermarking with certain maxOurOfOrderness time.
Sometimes, what happens is: during certain time, there is no incoming event, and then the watermark for triggering the window fire is not coming. Then, the last several records will be just stayed in the window. It will fire only when the window sees the watermark to trigger. What I would like to achieve is: if there is no just watermark coming within certain time (maybe this time is system clock time?), I can still trigger the window to fire no matter whether there is new event coming or not. Then I can still get the window count for this window, without waiting the next event, which could be coming after a long time. Do you have any idea how can I do this? Many Thanks :) Best regards/祝好, Chang Liu 刘畅
