Hi Team, When a flink job fails we use an implementation of joblistener interface to get an handle of onJobSubmitted(job submitted) and onJobExecuted(failure,success). But if my flink application has restart strategy enabled flink automatically restarts specific task(which fail). How do we get an handle before/after a task is restarted? We need a custom logic to be run before/after a task is restarted. Is there any way to achieve it?
Regards. Vicky
