Repository: spark Updated Branches: refs/heads/master 8d271c90f -> ef690e1f6
Fixed the error message for OutOfMemoryError in DAGScheduler. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/ef690e1f Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/ef690e1f Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/ef690e1f Branch: refs/heads/master Commit: ef690e1f69cb8e2e03bb0c43e3ccb2c54c995df7 Parents: 8d271c9 Author: Reynold Xin <[email protected]> Authored: Mon May 26 21:31:27 2014 -0700 Committer: Reynold Xin <[email protected]> Committed: Mon May 26 21:31:27 2014 -0700 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/ef690e1f/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala ---------------------------------------------------------------------- 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 c70aa0e..ccff6a3 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 {
