pyspark.BarrierTaskContext.attemptNumber

BarrierTaskContext。 attemptNumber ( )→int

“这个任务已经尝试多少次。第一个任务尝试将分配attemptNumber = 0,和随后的尝试将会增加数量。