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
26
26
import scala .concurrent .duration ._
27
27
import scala .language .postfixOps
28
28
import scala .reflect .ClassTag
29
+ import scala .util .control .NonFatal
29
30
30
31
import akka .actor ._
31
32
import akka .actor .OneForOneStrategy
@@ -768,7 +769,7 @@ class DAGScheduler(
768
769
abortStage(stage, " Task not serializable: " + e.toString)
769
770
runningStages -= stage
770
771
return
771
- case e : Throwable => // Other exceptions, such as IllegalArgumentException from Kryo.
772
+ case NonFatal (e) => // Other exceptions, such as IllegalArgumentException from Kryo.
772
773
abortStage(stage, " Task serialization failed: " + e.toString)
773
774
runningStages -= stage
774
775
return
You can’t perform that action at this time.
0 commit comments