class TaskInfo extends AnyRef
Information about a running task attempt inside a TaskSet.
- Annotations
- @DeveloperApi()
- Source
- TaskInfo.scala
- Alphabetic
- By Inheritance
- TaskInfo
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
TaskInfo(taskId: Long, index: Int, attemptNumber: Int, launchTime: Long, executorId: String, host: String, taskLocality: TaskLocality.TaskLocality, speculative: Boolean)
This api doesn't contains partitionId, please use the new api.
This api doesn't contains partitionId, please use the new api. Remain it for backward compatibility before Spark 3.3.
- new TaskInfo(taskId: Long, index: Int, attemptNumber: Int, partitionId: Int, launchTime: Long, executorId: String, host: String, taskLocality: TaskLocality.TaskLocality, speculative: Boolean)
Value Members
-
def
accumulables: Seq[AccumulableInfo]
Intermediate updates to accumulables during this task.
Intermediate updates to accumulables during this task. Note that it is valid for the same accumulable to be updated multiple times in a single task or for two accumulables with the same name but different IDs to exist in a task.
- val attemptNumber: Int
- def duration: Long
- val executorId: String
- var failed: Boolean
-
var
finishTime: Long
The time when the task has completed successfully (including the time to remotely fetch results, if necessary).
- def finished: Boolean
- def gettingResult: Boolean
-
var
gettingResultTime: Long
The time when the task started remotely getting the result.
The time when the task started remotely getting the result. Will not be set if the task result was sent immediately when the task finished (as opposed to sending an IndirectTaskResult and later fetching the result from the block manager).
- val host: String
- def id: String
- val index: Int
- var killed: Boolean
- val launchTime: Long
- var launching: Boolean
- val partitionId: Int
- def running: Boolean
- val speculative: Boolean
- def status: String
- def successful: Boolean
- val taskId: Long
- val taskLocality: TaskLocality.TaskLocality