Skip to content
Snippets Groups Projects
Commit 7375047d authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Merge pull request #304 from kayousterhout/remove_unused

Removed unused failed and causeOfFailure variables (in TaskSetManager)
parents ad3dfd15 baaabced
No related branches found
No related tags found
No related merge requests found
...@@ -112,10 +112,6 @@ private[spark] class TaskSetManager( ...@@ -112,10 +112,6 @@ private[spark] class TaskSetManager(
// Task index, start and finish time for each task attempt (indexed by task ID) // Task index, start and finish time for each task attempt (indexed by task ID)
val taskInfos = new HashMap[Long, TaskInfo] 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 // How frequently to reprint duplicate exceptions in full, in milliseconds
val EXCEPTION_PRINT_INTERVAL = val EXCEPTION_PRINT_INTERVAL =
System.getProperty("spark.logging.exceptionPrintInterval", "10000").toLong System.getProperty("spark.logging.exceptionPrintInterval", "10000").toLong
...@@ -556,8 +552,6 @@ private[spark] class TaskSetManager( ...@@ -556,8 +552,6 @@ private[spark] class TaskSetManager(
} }
def abort(message: String) { def abort(message: String) {
failed = true
causeOfFailure = message
// TODO: Kill running tasks if we were not terminated due to a Mesos error // TODO: Kill running tasks if we were not terminated due to a Mesos error
sched.dagScheduler.taskSetFailed(taskSet, message) sched.dagScheduler.taskSetFailed(taskSet, message)
removeAllRunningTasks() removeAllRunningTasks()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment