pyspark.BarrierTaskContext.taskAttemptId

BarrierTaskContext.taskAttemptId() → int

An ID that is unique to this task attempt (within the same SparkContext, no two task attempts will share the same attempt ID). This is roughly equivalent to Hadoop’s TaskAttemptID.

Returns

int

current task attempt id.

pyspark.BarrierTaskContext.stageId pyspark.util.VersionUtils.majorMinorVersion