diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
index f74425d73b392..29c8b4a81bcf2 100644
--- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
+++ b/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 =>
+        abortStage(stage, s"Task serialization failed:  $e\n${Utils.exceptionString(e)}", Some(e))
+        runningStages -= stage
+
+        // Abort execution
+        return
     }
 
     val tasks: Seq[Task[_]] = try {