Hi Felipe, You can use getRuntimeContext().getAttemptNumber() [1] (but beware that depending on the configuration only a pipeline region can be restarted, not the whole job).
But if all you want is to check whether it's a first attempt or not, you can also call context.isRestored() from initializeState() [2] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/api/java/org/apache/flink/api/common/functions/RuntimeContext.html#getAttemptNumber-- [2] https://ci.apache.org/projects/flink/flink-docs-release-1.13/api/java/org/apache/flink/runtime/state/ManagedInitializationContext.html#isRestored-- Regards, Roman On Thu, Jun 10, 2021 at 5:30 PM Felipe Gutierrez <felipe.o.gutier...@gmail.com> wrote: > > Hello community, > > Is it possible to know programmatically how many times my Flink stream job > restarted since it was running? > > My use case is like this. I have an Unit test that uses checkpoint and I > throw one exception in a MapFunction for a given time, i.e.: for the 2 > seconds ahead. Because Flink restarts the job and I have checkpoint I can > recover the state and after 2 seconds I don't throw any exception anymore. > Then I would like to know how many times the job was restarted. > > Thanks, > Felipe >
