flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [2/9] flink git commit: [FLINK-8931] TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled
Date Fri, 23 Mar 2018 11:40:15 GMT
[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/69114a4f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/69114a4f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/69114a4f

Branch: refs/heads/release-1.5
Commit: 69114a4f9b6dbbda2929b88903dda8a91a0f49fe
Parents: 2344ce2
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:39:29 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/69114a4f/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