diff options
| author | Kay Ousterhout <kayousterhout@gmail.com> | 2013-12-27 11:12:36 -0800 |
|---|---|---|
| committer | Kay Ousterhout <kayousterhout@gmail.com> | 2013-12-27 11:12:36 -0800 |
| commit | baaabcedc9225519c728ea34619b2c824aa9ac89 (patch) | |
| tree | 25ab8c7d2ce1f2d25326ceb653cccb8b8a79f3a8 | |
| parent | 7be1e57786005e52b71238425d4557bb6d1311cc (diff) | |
| download | spark-baaabcedc9225519c728ea34619b2c824aa9ac89.tar.gz spark-baaabcedc9225519c728ea34619b2c824aa9ac89.tar.bz2 spark-baaabcedc9225519c728ea34619b2c824aa9ac89.zip | |
Removed unused failed and causeOfFailure variables
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala index c676e73e03..26caeeda58 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala @@ -112,10 +112,6 @@ private[spark] class TaskSetManager( // Task index, start and finish time for each task attempt (indexed by task ID) val taskInfos = new HashMap[Long, TaskInfo] - // Did the TaskSet fail? - var failed = false - var causeOfFailure = "" - // How frequently to reprint duplicate exceptions in full, in milliseconds val EXCEPTION_PRINT_INTERVAL = System.getProperty("spark.logging.exceptionPrintInterval", "10000").toLong @@ -556,8 +552,6 @@ private[spark] class TaskSetManager( } def abort(message: String) { - failed = true - causeOfFailure = message // TODO: Kill running tasks if we were not terminated due to a Mesos error sched.dagScheduler.taskSetFailed(taskSet, message) removeAllRunningTasks() |