yjshen commented on issue #5866: Flink event time based windowing functions not working with pulsar URL: https://github.com/apache/pulsar/issues/5866#issuecomment-568853093 Hi @subbu107 , thanks for the log. Regarding the log, your watermark seems to be Long.minvalue and never changes, I think this could be the reason: ``` 2019-12-25 11:23:37,311 INFO com.microfocus.sample.flink.window.MovingAverageTrigger - ONELEMENT: [TimeWindow: Mon Dec 16 10:44:40 IST 2019 - Mon Dec 16 10:44:50 IST 2019] , [Watermark: -9223372036854775808 , date: "1576473289344"], Element: "btpvm0933.hpeswlab.net"_1576473289999, window MaxTimestamp: {} 2019-12-25 11:23:37,311 INFO com.microfocus.sample.flink.window.MovingAverageTrigger - [windowDeadline : 1577253227295, (Wed Dec 25 11:23:47 IST 2019) ] 2019-12-25 11:23:37,311 INFO com.microfocus.sample.flink.window.MovingAverageTrigger - Time field value Mon Dec 16 10:44:49 IST 2019 2019-12-25 11:23:37,311 INFO com.microfocus.sample.flink.window.MovingAverageTrigger - current watermark Sun Dec 02 22:17:04 IST 292269055 2019-12-25 11:23:37,311 INFO com.microfocus.sample.flink.window.MovingAverageTrigger - ------Time field value is greater than current watermark----- ``` and your code path never when to `FIRE_AND_PURGE` branch, therefore window never fired
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
