You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2013/12/28 22:25:24 UTC
[1/2] git commit: Removed unused failed and causeOfFailure variables
Updated Branches:
refs/heads/master ad3dfd153 -> 7375047d5
Removed unused failed and causeOfFailure variables
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/baaabced
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/baaabced
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/baaabced
Branch: refs/heads/master
Commit: baaabcedc9225519c728ea34619b2c824aa9ac89
Parents: 7be1e57
Author: Kay Ousterhout <ka...@gmail.com>
Authored: Fri Dec 27 11:12:36 2013 -0800
Committer: Kay Ousterhout <ka...@gmail.com>
Committed: Fri Dec 27 11:12:36 2013 -0800
----------------------------------------------------------------------
.../main/scala/org/apache/spark/scheduler/TaskSetManager.scala | 6 ------
1 file changed, 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/baaabced/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala
----------------------------------------------------------------------
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 c676e73..26caeed 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()
[2/2] git commit: Merge pull request #304 from
kayousterhout/remove_unused
Posted by pw...@apache.org.
Merge pull request #304 from kayousterhout/remove_unused
Removed unused failed and causeOfFailure variables (in TaskSetManager)
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/7375047d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/7375047d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/7375047d
Branch: refs/heads/master
Commit: 7375047d516c5aa69221611f5f7b0f1d367039af
Parents: ad3dfd1 baaabce
Author: Patrick Wendell <pw...@gmail.com>
Authored: Sat Dec 28 13:25:06 2013 -0800
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Sat Dec 28 13:25:06 2013 -0800
----------------------------------------------------------------------
.../main/scala/org/apache/spark/scheduler/TaskSetManager.scala | 6 ------
1 file changed, 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/7375047d/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala
----------------------------------------------------------------------