Skip to content

Commit ef690e1

Browse files
committed
Fixed the error message for OutOfMemoryError in DAGScheduler.
1 parent 8d271c9 commit ef690e1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -581,7 +581,7 @@ class DAGScheduler(
581581
jobResult = JobFailed(e)
582582
job.listener.jobFailed(e)
583583
case oom: OutOfMemoryError =>
584-
val exception = new SparkException("job failed for Out of memory exception", oom)
584+
val exception = new SparkException("Local job aborted due to out of memory error", oom)
585585
jobResult = JobFailed(exception)
586586
job.listener.jobFailed(exception)
587587
} finally {

0 commit comments

Comments
 (0)