Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21165#discussion_r184438550
--- Diff: core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
---
@@ -1417,10 +1417,13 @@ class DAGScheduler(
case exceptionFailure: ExceptionFailure =>
// Nothing left to do, already handled above for accumulator
updates.
+ case _: TaskKilled =>
--- End diff --
nit: combine this with the `ExceptionFailure` case.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
