Hi,

I need to pass more context information between registering a timer and 
executing it.
For instance, I’d need to register 2 different timers in processElement() 
method, each one for different purposes.

Is there any other way to pass some information between registering the timers 
and executing them? My only idea for now is to keep a MapState with the timers’ 
timestamps as keys and context that I want to pass as value. However, I’d like 
to have the possibility to put some data into the Context object that Flink 
passes into onTimer() method.

Thanks,
Vadim.

Reply via email to