case class TaskKilled(reason: String, accumUpdates: Seq[AccumulableInfo] = Seq.empty, accums: Seq[AccumulatorV2[_, _]] = Nil, metricPeaks: Seq[Long] = Seq.empty) extends TaskFailedReason with Product with Serializable
Task was killed intentionally and needs to be rescheduled.
- Annotations
- @DeveloperApi()
- Source
- TaskEndReason.scala
- Alphabetic
- By Inheritance
- TaskKilled
- Serializable
- Serializable
- Product
- Equals
- TaskFailedReason
- TaskEndReason
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new TaskKilled(reason: String, accumUpdates: Seq[AccumulableInfo] = Seq.empty, accums: Seq[AccumulatorV2[_, _]] = Nil, metricPeaks: Seq[Long] = Seq.empty)
Value Members
- val accumUpdates: Seq[AccumulableInfo]
-
def
countTowardsTaskFailures: Boolean
Whether this task failure should be counted towards the maximum number of times the task is allowed to fail before the stage is aborted.
Whether this task failure should be counted towards the maximum number of times the task is allowed to fail before the stage is aborted. Set to false in cases where the task's failure was unrelated to the task; for example, if the task failed because the executor it was running on was killed.
- Definition Classes
- TaskKilled → TaskFailedReason
- val metricPeaks: Seq[Long]
- val reason: String
-
def
toErrorString: String
Error message displayed in the web UI.
Error message displayed in the web UI.
- Definition Classes
- TaskKilled → TaskFailedReason