Packages

class TaskInfo extends AnyRef

Developer API

Information about a running task attempt inside a TaskSet.

Annotations
@DeveloperApi()
Source
TaskInfo.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TaskInfo
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. 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.

  2. new TaskInfo(taskId: Long, index: Int, attemptNumber: Int, partitionId: Int, launchTime: Long, executorId: String, host: String, taskLocality: TaskLocality.TaskLocality, speculative: Boolean)

Value Members

  1. 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.

  2. val attemptNumber: Int
  3. def duration: Long
  4. val executorId: String
  5. var failed: Boolean
  6. var finishTime: Long

    The time when the task has completed successfully (including the time to remotely fetch results, if necessary).

  7. def finished: Boolean
  8. def gettingResult: Boolean
  9. 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).

  10. val host: String
  11. def id: String
  12. val index: Int
  13. var killed: Boolean
  14. val launchTime: Long
  15. var launching: Boolean
  16. val partitionId: Int
  17. def running: Boolean
  18. val speculative: Boolean
  19. def status: String
  20. def successful: Boolean
  21. val taskId: Long
  22. val taskLocality: TaskLocality.TaskLocality