diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-12-28 13:25:06 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-12-28 13:25:06 -0800 |
| commit | 7375047d516c5aa69221611f5f7b0f1d367039af (patch) | |
| tree | 2ad9eee2e11d2236eb59dbfb46afdc4ca3966369 /core | |
| parent | ad3dfd153196497fefe6c1925e0a495a4373f1c5 (diff) | |
| parent | baaabcedc9225519c728ea34619b2c824aa9ac89 (diff) | |
| download | spark-7375047d516c5aa69221611f5f7b0f1d367039af.tar.gz spark-7375047d516c5aa69221611f5f7b0f1d367039af.tar.bz2 spark-7375047d516c5aa69221611f5f7b0f1d367039af.zip | |
Merge pull request #304 from kayousterhout/remove_unused
Removed unused failed and causeOfFailure variables (in TaskSetManager)
Diffstat (limited to 'core')
| -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 9b95e418d8..7929051791 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() |