Github user jiangxb1987 commented on a diff in the pull request:
https://github.com/apache/spark/pull/21758#discussion_r203736592
--- Diff: core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
---
@@ -1311,17 +1312,6 @@ class DAGScheduler(
}
}
- case Resubmitted =>
--- End diff --
We may have a barrier task failed with reason Resubmitted, so `case
Resubmitted` must be after `case failure: TaskFailedReason if task.isBarrier`,
and we must make sure that the task failed reasons (except for FetchFailed) are
handled inside the barrier task failure handling logic.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
