Packages

c

org.apache.spark

TaskCommitDenied

case class TaskCommitDenied(jobID: Int, partitionID: Int, attemptNumber: Int) extends TaskFailedReason with Product with Serializable

Developer API

Task requested the driver to commit, but was denied.

Annotations
@DeveloperApi()
Source
TaskEndReason.scala
Linear Supertypes
Serializable, Serializable, Product, Equals, TaskFailedReason, TaskEndReason, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TaskCommitDenied
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. TaskFailedReason
  7. TaskEndReason
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TaskCommitDenied(jobID: Int, partitionID: Int, attemptNumber: Int)

Value Members

  1. val attemptNumber: Int
  2. def countTowardsTaskFailures: Boolean

    If a task failed because its attempt to commit was denied, do not count this failure towards failing the stage.

    If a task failed because its attempt to commit was denied, do not count this failure towards failing the stage. This is intended to prevent spurious stage failures in cases where many speculative tasks are launched and denied to commit.

    Definition Classes
    TaskCommitDeniedTaskFailedReason
  3. val jobID: Int
  4. val partitionID: Int
  5. def toErrorString: String

    Error message displayed in the web UI.

    Error message displayed in the web UI.

    Definition Classes
    TaskCommitDeniedTaskFailedReason