Hi Members,

I am currently working on a project for which we need to do some
modifications in our streaming application. We are using Flink to achieve
that.

One of the technical requirements is to pause the processing of Timer
Messages temporarily (lets say 5 mins) and then start the processing of the
timer messages.

How can we achieve this?

I found the API to Shutdown the TimerService for our application, but could
not find anything to restart it again.

Additional questions

1. If I shutdown the timer Service, the call to `RegisterProcessingTimer`
would fail, will it also delete the timers which were already registered?

My use case is that I want to register the timers but don't want the
`OnTimer(...) method to get invoked.

How can I achieve such functionality?

Thank you in advance for getting back to me.

Regards,
Rajat Gupta

Reply via email to