flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [FLINK-7899] Harden SlotManagerTest#testTaskManagerTimeoutDoesNotRemoveSlots by increasing timeout
Date Mon, 23 Oct 2017 07:32:33 GMT
Repository: flink
Updated Branches:
  refs/heads/master 14484db38 -> 25c95f28f


[FLINK-7899] Harden SlotManagerTest#testTaskManagerTimeoutDoesNotRemoveSlots by increasing
timeout


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

Branch: refs/heads/master
Commit: 25c95f28f7ab0eccf20435c562f1a316671c6738
Parents: 14484db
Author: Till Rohrmann <trohrmann@apache.org>
Authored: Mon Oct 23 09:31:58 2017 +0200
Committer: Till Rohrmann <trohrmann@apache.org>
Committed: Mon Oct 23 09:31:58 2017 +0200

----------------------------------------------------------------------
 .../flink/runtime/resourcemanager/slotmanager/SlotManagerTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/25c95f28/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerTest.java
index c4c320a..cf0aef9 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerTest.java
@@ -1057,7 +1057,7 @@ public class SlotManagerTest extends TestLogger {
 			assertEquals(1, slotManager.getNumberRegisteredSlots());
 
 			// wait for the timeout call to happen
-			verify(resourceActions, timeout(taskManagerTimeout.toMilliseconds() * 3L).atLeast(1)).releaseResource(eq(taskExecutorConnection.getInstanceID()));
+			verify(resourceActions, timeout(taskManagerTimeout.toMilliseconds() * 20L).atLeast(1)).releaseResource(eq(taskExecutorConnection.getInstanceID()));
 
 			assertEquals(1, slotManager.getNumberRegisteredSlots());
 


Mime
View raw message