diff options
| author | Kay Ousterhout <kayousterhout@gmail.com> | 2013-12-27 15:51:27 -0800 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2013-12-27 15:51:27 -0800 |
| commit | e17d7518ab10c218c9576db5754c7fa4cb92688a (patch) | |
| tree | d0d69e34b18253299d7bbed239159f8d148c329b /core | |
| parent | 19672dca32e41b63dce88b682690ac256b536c8f (diff) | |
| download | spark-e17d7518ab10c218c9576db5754c7fa4cb92688a.tar.gz spark-e17d7518ab10c218c9576db5754c7fa4cb92688a.tar.bz2 spark-e17d7518ab10c218c9576db5754c7fa4cb92688a.zip | |
Removed unused OtherFailure TaskEndReason.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/TaskEndReason.scala | 2 | ||||
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/JobLogger.scala | 4 |
2 files changed, 0 insertions, 6 deletions
diff --git a/core/src/main/scala/org/apache/spark/TaskEndReason.scala b/core/src/main/scala/org/apache/spark/TaskEndReason.scala index c1e5e04b31..faf6dcd618 100644 --- a/core/src/main/scala/org/apache/spark/TaskEndReason.scala +++ b/core/src/main/scala/org/apache/spark/TaskEndReason.scala @@ -53,5 +53,3 @@ private[spark] case class ExceptionFailure( private[spark] case object TaskResultLost extends TaskEndReason private[spark] case object TaskKilled extends TaskEndReason - -private[spark] case class OtherFailure(message: String) extends TaskEndReason diff --git a/core/src/main/scala/org/apache/spark/scheduler/JobLogger.scala b/core/src/main/scala/org/apache/spark/scheduler/JobLogger.scala index 60927831a1..be5c95e59e 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/JobLogger.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/JobLogger.scala @@ -328,10 +328,6 @@ class JobLogger(val user: String, val logDirName: String) task.stageId + " SHUFFLE_ID=" + shuffleId + " MAP_ID=" + mapId + " REDUCE_ID=" + reduceId stageLogInfo(task.stageId, taskStatus) - case OtherFailure(message) => - taskStatus += " STATUS=FAILURE TID=" + taskInfo.taskId + - " STAGE_ID=" + task.stageId + " INFO=" + message - stageLogInfo(task.stageId, taskStatus) case _ => } } |