Hi all,

In Flink, after setting the time characteristic to event time and properly 
assigning timestamps/watermarks, time-based windows will be created based upon 
event time. If we need to process events within a window in event time order, 
we can sort the windowed values and process as necessary by applying a 
WindowFunction. However, as I understand it, there is no guarantee that 
time-based windows will be processed in time order. Is this correct? Or, if we 
assume a watermarking system that (for example's sake) does not allow any late 
events, is there a way within Flink to guarantee that windows will be processed 
(via an applied WindowFunction) in strictly increasing time order?

If necessary, I can provide a more concrete explanation of what I mean/am 
looking for.

Thanks!
David

Reply via email to