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

Reply via email to