Package org.apache.spark

Class TaskCommitDenied

Object
org.apache.spark.TaskCommitDenied
All Implemented Interfaces:
Serializable, TaskEndReason, TaskFailedReason, scala.Equals, scala.Product, scala.Serializable
public class TaskCommitDenied extends Object implements TaskFailedReason, scala.Product, scala.Serializable
:: DeveloperApi :: Task requested the driver to commit, but was denied.
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    TaskCommitDenied(int jobID, int partitionID, int attemptNumber)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    abstract static R
    apply(T1 v1, T2 v2, T3 v3)
     
    int
    attemptNumber()
     
    boolean
    countTowardsTaskFailures()
    If a task failed because its attempt to commit was denied, do not count this failure towards failing the stage.
    int
    jobID()
     
    int
    partitionID()
     
    String
    toErrorString()
    Error message displayed in the web UI.
    static String
    toString()
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface scala.Equals

    canEqual, equals

    Methods inherited from interface scala.Product

    productArity, productElement, productIterator, productPrefix

  • Constructor Details

    • TaskCommitDenied

      public TaskCommitDenied(int jobID, int partitionID, int attemptNumber)

  • Method Details

    • apply

      public abstract static R apply(T1 v1, T2 v2, T3 v3)

    • toString

      public static String toString()

    • jobID

      public int jobID()

    • partitionID

      public int partitionID()

    • attemptNumber

      public int attemptNumber()

    • toErrorString

      public String toErrorString()
      Description copied from interface: TaskFailedReason
      Error message displayed in the web UI.
      Specified by:
      toErrorString in interface TaskFailedReason

    • countTowardsTaskFailures

      public boolean countTowardsTaskFailures()
      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.
      Specified by:
      countTowardsTaskFailures in interface TaskFailedReason
      Returns:
      (undocumented)