Re: Clarifying ProcessFunction.onTimer and watermark behavior

2022-03-18 Thread Yun Gao
Hi Dan, The default implementation in Flink [1] would first process all the timers before emit the watermark out, Thus the watermark should be after the records emitted in processing timers. Best, Yun Gao [1] https://github.com/apache/flink/blob/ab08b52030a9612571896c579d85e000134ad0f1/flink-

Clarifying ProcessFunction.onTimer and watermark behavior

2022-03-17 Thread Dan Hill
Hi. This Flink page says the following: “With event-time timers, the onTimer(...) method is called when the current watermark is advanced up to or beyond the timestamp of the timer” The do