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

Reply via email to