You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by "Vararu, Vadim via user" <us...@flink.apache.org> on 2025/05/05 20:33:51 UTC
Does Flink guarantee the same timestamp at onTimer() as the one registered at registerProcessingTimeTimer()?
Hi,
Could not find in the documentation if Flink guarantees to pass exactly the same timestamp at onTimer(timestamp) execution as the one specified at registerProcessingTimeTimer(timestamp)?
I would like to pass some state between registerProcessingTimeTimer() and onTimer() and cannot imagine another way but storing in state a map with onTimer registered timestamp as key. For that, I’d like to be sure that Flink will always pass the same timestamp as registered regardless if the exeution of onTimer() is 1 millisecond earlier or later.
Cheers,
Vadim