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 c70aa0e6e452331cd466216a33f1d85e175db3f7..ccff6a3d1aebccf9d8ae6ab6f586b7684858adb0 100644
--- 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 {