Hi, Could you please provide a snipped of code or some minimal example that would help us reproducing your problem?
Best, Aljoscha > On 3. Aug 2017, at 17:41, aitozi <gjying1...@gmail.com> wrote: > > > 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.
