flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [2/2] flink git commit: [FLINK-2006] [runtime] Fix testing TaskManager task status request to stabilize tests.
Date Wed, 13 May 2015 18:01:41 GMT
[FLINK-2006] [runtime] Fix testing TaskManager task status request to stabilize tests.


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

Branch: refs/heads/master
Commit: 9da2f1f725473f1242067acb546607888e3a5015
Parents: 48e21a1
Author: Stephan Ewen <sewen@apache.org>
Authored: Wed May 13 14:23:47 2015 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Wed May 13 18:26:26 2015 +0200

----------------------------------------------------------------------
 .../apache/flink/runtime/testingUtils/TestingTaskManager.scala   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/9da2f1f7/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManager.scala
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManager.scala
b/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManager.scala
index 5318254..220e6ca 100644
--- a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManager.scala
+++ b/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/TestingTaskManager.scala
@@ -71,8 +71,8 @@ class TestingTaskManager(config: TaskManagerConfiguration,
   def receiveTestMessages: Receive = {
     case NotifyWhenTaskIsRunning(executionID) => {
       Option(runningTasks.get(executionID)) match {
-        case Some(_) => sender ! true
-        case None =>
+        case Some(task) if task.getExecutionState == ExecutionState.RUNNING => sender
! true
+        case _ =>
           val listeners = waitForRunning.getOrElse(executionID, Set())
           waitForRunning += (executionID -> (listeners + sender))
       }


Mime
View raw message