You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2019/12/25 07:43:19 UTC
[GitHub] [pulsar] yjshen edited a comment on issue #5866: Flink event time
based windowing functions not working with pulsar
yjshen edited a comment 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 went 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:
users@infra.apache.org
With regards,
Apache Git Services