Hi, i have encounted a problem, i apply generate and assign watermark at the datastream, and then keyBy, and EventTimewindow and apply window Function.
in the log, i can see that watermark and the eventtime with the message are correct , and i think the situation bellow will trigger the window function : 1、watermark Time >= window_end_time 2、there is data in [window_start_time,window_end_time) i check the log , it is satisfied . and i try to apply the trigger(CountTrigger.of(5)) Function and i can see in the log the windowapply Function is invocked. And i am doubt why is the windowapply Function can not be triggerd only by the event time and watermark thanks, aitozi -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/WaterMark-Eventwindow-not-fired-correctly-tp14668.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
