File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
core/src/main/scala/org/apache/spark/scheduler Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -26,6 +26,7 @@ import scala.concurrent.Await
2626import scala .concurrent .duration ._
2727import scala .language .postfixOps
2828import scala .reflect .ClassTag
29+ import scala .util .control .NonFatal
2930
3031import akka .actor ._
3132import akka .actor .OneForOneStrategy
@@ -768,7 +769,7 @@ class DAGScheduler(
768769 abortStage(stage, " Task not serializable: " + e.toString)
769770 runningStages -= stage
770771 return
771- case e : Throwable => // Other exceptions, such as IllegalArgumentException from Kryo.
772+ case NonFatal (e) => // Other exceptions, such as IllegalArgumentException from Kryo.
772773 abortStage(stage, " Task serialization failed: " + e.toString)
773774 runningStages -= stage
774775 return
You can’t perform that action at this time.
0 commit comments