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
     
    boolean
    If a task failed because its attempt to commit was denied, do not count this failure towards failing the stage.
    int
     
    int
     
    Error message displayed in the web UI.
    static String
     

    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)