Re: Periodic output at end of stream

Hi Matthias, Thanks for providing the example, I would reply back soon after I do some debug. Best, JING ZHANG Matthias Broecheler 于2021年8月19日周四 上午1:53写道： > Hey JING, > > thanks for getting back to me. I tried to produce the smallest, > self-contained example that produces the phenomenon: > htt

Re: Periodic output at end of stream

Hey JING, thanks for getting back to me. I tried to produce the smallest, self-contained example that produces the phenomenon: https://gist.github.com/mbroecheler/fd27dd8a810b038ec463cdd5339d290f If you run MainRepl you should see an infinite loop of re-processing the 5 integers. The offending pr

Re: Periodic output at end of stream

Hi Matthias, How often do you register the event-time timer? It is registered per input record, or re-registered a new timer after an event-time timer is triggered? Would you please provide your test case code, it would be very helpful for troubleshooting. Best wishes, JING ZHANG Matthias Broeche

Periodic output at end of stream

Hey guys, I have a KeyedProcessFunction that gathers statistics on the events that flow through and emits it periodically (every few seconds) to a SideOutput. However, at the end of stream the last set of statistics don't get emitted. I read on the mailing list that processing time timers that are