Hi.

This Flink page
<https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/operators/process_function/>
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 doc doesn't describe the behavior of the collect(...) in onTimer
(related to timestamps and watermarks). If the watermark can be later than
the timestamps, will the watermark propagation be delayed until the
previous timers have fired?

I'm evaluating corner cases in the operators that might cause watermarks to
become more recent than record times.

Reply via email to