pyflink.datastream.functions.RuntimeContext.get_attempt_number

abstract RuntimeContext.get_attempt_number() → int

Gets the attempt number of this parallel subtask. First attempt is numbered 0.