Fixed the error message for OutOfMemoryError in DAGScheduler.

apache · May 27, 2014 · ef690e1 · ef690e1
1 parent 8d271c9
commit ef690e1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -581,7 +581,7 @@ class DAGScheduler(
         jobResult = JobFailed(e)
         job.listener.jobFailed(e)
       case oom: OutOfMemoryError =>
-        val exception = new SparkException("job failed for Out of memory exception", oom)
+        val exception = new SparkException("Local job aborted due to out of memory error", oom)
         jobResult = JobFailed(exception)
         job.listener.jobFailed(exception)
     } finally {