spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r...@apache.org
Subject git commit: Fixed the error message for OutOfMemoryError in DAGScheduler.
Date Tue, 27 May 2014 04:31:54 GMT
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 <rxin@apache.org>
Authored: Mon May 26 21:31:27 2014 -0700
Committer: Reynold Xin <rxin@apache.org>
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 {


Mime
View raw message