Skip to content

Commit 76f7eda

Browse files
committed
remove redundant memory allocations
1 parent aa63161 commit 76f7eda

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

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

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -581,10 +581,7 @@ class DAGScheduler(
581581
jobResult = JobFailed(e)
582582
job.listener.jobFailed(e)
583583
case oom: OutOfMemoryError =>
584-
val errors: StringWriter = new StringWriter()
585-
oom.printStackTrace(new PrintWriter(errors))
586-
val exception = new SparkException("job failed for: " + oom.getMessage() +
587-
"\n" + errors.toString())
584+
val exception = new SparkException("job failed for Out of memory exception", oom)
588585
jobResult = JobFailed(exception)
589586
job.listener.jobFailed(exception)
590587
} finally {

0 commit comments

Comments
 (0)