Github user jerryshao commented on a diff in the pull request:
https://github.com/apache/spark/pull/21664#discussion_r200220083
--- Diff: core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
---
@@ -1049,6 +1049,13 @@ class DAGScheduler(
abortStage(stage, s"Task serialization failed:
$e\n${Utils.exceptionString(e)}", Some(e))
runningStages -= stage
return
+
+ case e: NoClassDefFoundError =>
--- End diff --
This exception is actually a fatal error. I'm not sure if need to fix it or
just let it fail.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
