diff options
| author | Reynold Xin <rxin@apache.org> | 2014-06-25 00:19:33 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-06-25 00:19:33 -0700 |
| commit | c68be53d0cfc4ba689ee29a8dc0befd8cbd31eeb (patch) | |
| tree | 1d43b9a6a1e472f64ef9c730d72ed003708701b4 | |
| parent | 65a559cfc3e893c4fdc58810e63f24b670a192e0 (diff) | |
| download | spark-c68be53d0cfc4ba689ee29a8dc0befd8cbd31eeb.tar.gz spark-c68be53d0cfc4ba689ee29a8dc0befd8cbd31eeb.tar.bz2 spark-c68be53d0cfc4ba689ee29a8dc0befd8cbd31eeb.zip | |
[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 <rxin@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
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskResultGetter.scala | 3 |
1 files changed, 2 insertions, 1 deletions
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 99d305b36a..df59f444b7 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)) } } }) |