case class TaskCommitDenied(jobID: Int, partitionID: Int, attemptNumber: Int) extends TaskFailedReason with Product with Serializable
Task requested the driver to commit, but was denied.
- Annotations
- @DeveloperApi()
- Source
- TaskEndReason.scala
- Alphabetic
- By Inheritance
- TaskCommitDenied
- Serializable
- Serializable
- Product
- Equals
- TaskFailedReason
- TaskEndReason
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new TaskCommitDenied(jobID: Int, partitionID: Int, attemptNumber: Int)
Value Members
- val attemptNumber: Int
-
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
- TaskCommitDenied → TaskFailedReason
- val jobID: Int
- val partitionID: Int
-
def
toErrorString: String
Error message displayed in the web UI.
Error message displayed in the web UI.
- Definition Classes
- TaskCommitDenied → TaskFailedReason