diff options
| author | Matei Zaharia <matei@databricks.com> | 2013-12-27 22:10:14 -0500 |
|---|---|---|
| committer | Matei Zaharia <matei@databricks.com> | 2013-12-27 22:10:14 -0500 |
| commit | ad3dfd153196497fefe6c1925e0a495a4373f1c5 (patch) | |
| tree | a69078e0deea88ef97d043d9f69279eaf7e836bc | |
| parent | b579b83277e30abbfd952e169bba19dee878f85e (diff) | |
| parent | e17d7518ab10c218c9576db5754c7fa4cb92688a (diff) | |
| download | spark-ad3dfd153196497fefe6c1925e0a495a4373f1c5.tar.gz spark-ad3dfd153196497fefe6c1925e0a495a4373f1c5.tar.bz2 spark-ad3dfd153196497fefe6c1925e0a495a4373f1c5.zip | |
Merge pull request #307 from kayousterhout/other_failure
Removed unused OtherFailure TaskEndReason.
The OtherFailure TaskEndReason was added by @mateiz 3 years ago in this commit: https://github.com/apache/incubator-spark/commit/24a1e7f8380bfd8d4fbdda688482a451bd6ea215
Unless I am missing something, it doesn't seem to have been used then, and is not used now, so seems safe for deletion.
| -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 _ => } } |