We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 340e07c commit 5a409ceCopy full SHA for 5a409ce
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1045,14 +1045,9 @@ class DAGScheduler(
1045
1046
// Abort execution
1047
return
1048
- case NonFatal(e) =>
+ case e: Throwable =>
1049
abortStage(stage, s"Task serialization failed: $e\n${Utils.exceptionString(e)}", Some(e))
1050
runningStages -= stage
1051
- return
1052
-
1053
- case e: NoClassDefFoundError =>
1054
- abortStage(stage, s"Task serialization failed: $e\n${Utils.exceptionString(e)}", Some(e))
1055
- runningStages -= stage
1056
1057
1058
0 commit comments