yjshen commented on issue #5866: Flink event time based windowing functions not working with pulsar URL: https://github.com/apache/pulsar/issues/5866#issuecomment-568830441 Or could you simply remove `.trigger(new MovingAverageTrigger(timeField,0L,(long)windowSize))` and use the default trigger to see what's happening? BTW I think this issue is off-topic since the watermark generation and window trigger / proceessing are all constructed in the program instead of inside pulsar-flink connector.
---------------------------------------------------------------- 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
