Skip to content
Snippets Groups Projects
Commit c92dd627 authored by Kay Ousterhout's avatar Kay Ousterhout
Browse files

Properly account for killed tasks.

The TaskState class's isFinished() method didn't return true for
KILLED tasks, which means some resources are never reclaimed
for tasks that are killed. This also made it inconsistent with the
isFinished() method used by CoarseMesosSchedulerBackend.
parent 622f83ce
No related branches found
No related tags found
No related merge requests found
......@@ -26,7 +26,7 @@ private[spark] object TaskState
type TaskState = Value
def isFinished(state: TaskState) = Seq(FINISHED, FAILED, LOST).contains(state)
def isFinished(state: TaskState) = Seq(FINISHED, FAILED, KILLED, LOST).contains(state)
def toMesos(state: TaskState): MesosTaskState = state match {
case LAUNCHING => MesosTaskState.TASK_STARTING
......
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