[FLINK-8931] TASK_KILLING is not covered by match in TaskMonitor#when…

…Unhandled This closes apache#5744.
laubersder · Mar 23, 2018 · 6384aa7 · 6384aa7
1 parent cc94090
commit 6384aa7
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/TaskMonitor.scala b/flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/TaskMonitor.scala
@@ -163,6 +163,7 @@ class TaskMonitor(
  LOG.warn(s"Mesos task ${goal.taskID.getValue} failed unexpectedly.")
  context.parent ! TaskTerminated(goal.taskID, msg.status())
  stop()
+ case TASK_KILLING => stay()
  }
 
  case Event(msg: StatusUpdate, StateData(goal: Released)) =>
@@ -175,6 +176,7 @@ class TaskMonitor(
  LOG.info(s"Mesos task ${goal.taskID.getValue} exited as planned.")
  context.parent ! TaskTerminated(goal.taskID, msg.status())
  stop()
+ case TASK_KILLING => stay()
  }
  }