flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [1/9] flink git commit: [FLINK-8931] TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled
Date Fri, 23 Mar 2018 11:38:30 GMT
Repository: flink
Updated Branches:
  refs/heads/master cc94090ea -> 9ee02f6a3


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

This closes #5744.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6384aa7a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6384aa7a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6384aa7a

Branch: refs/heads/master
Commit: 6384aa7a3b2a752ebf41475748288ab1489fafa7
Parents: cc94090
Author: yanghua <yanghua1127@gmail.com>
Authored: Thu Mar 22 09:58:08 2018 +0800
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Fri Mar 23 12:32:36 2018 +0100

----------------------------------------------------------------------
 .../main/scala/org/apache/flink/mesos/scheduler/TaskMonitor.scala  | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/6384aa7a/flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/TaskMonitor.scala
----------------------------------------------------------------------
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
index 7840fd4..76a2a90 100644
--- 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()
       }
   }
 


Mime
View raw message