Repository: spark Updated Branches: refs/heads/branch-1.0 65a559cfc -> c68be53d0
[SPARK-2267] Log exception when TaskResultGetter fails to fetch/deserialze task result Note that this is only for branch-1.0 because master's been fixed. Author: Reynold Xin <r...@apache.org> Closes #1202 from rxin/SPARK-2267 and squashes the following commits: ce1b19b [Reynold Xin] [SPARK-2267] Log exception when TaskResultGetter fails to fetch/deserialize task result Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c68be53d Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c68be53d Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c68be53d Branch: refs/heads/branch-1.0 Commit: c68be53d0cfc4ba689ee29a8dc0befd8cbd31eeb Parents: 65a559c Author: Reynold Xin <r...@apache.org> Authored: Wed Jun 25 00:19:33 2014 -0700 Committer: Reynold Xin <r...@apache.org> Committed: Wed Jun 25 00:19:33 2014 -0700 ---------------------------------------------------------------------- .../main/scala/org/apache/spark/scheduler/TaskResultGetter.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/c68be53d/core/src/main/scala/org/apache/spark/scheduler/TaskResultGetter.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskResultGetter.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskResultGetter.scala index 99d305b..df59f44 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskResultGetter.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskResultGetter.scala @@ -71,7 +71,8 @@ private[spark] class TaskResultGetter(sparkEnv: SparkEnv, scheduler: TaskSchedul val loader = Thread.currentThread.getContextClassLoader taskSetManager.abort("ClassNotFound with classloader: " + loader) case ex: Exception => - taskSetManager.abort("Exception while deserializing and fetching task: %s".format(ex)) + logError("Exception while getting task result", ex) + taskSetManager.abort("Exception while getting task result: %s".format(ex)) } } })
