You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/02/03 12:37:32 UTC

[6/6] flink git commit: [hotfix] [tests] Increase timeout for AkkaRpcActorTest to mitigate occasional CI test timeouts

[hotfix] [tests] Increase timeout for AkkaRpcActorTest to mitigate occasional CI test timeouts


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

Branch: refs/heads/master
Commit: 7b1857d849efd3611be797679b11e8c7b7ed61fb
Parents: b9ed4ff
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Feb 3 11:25:12 2017 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Feb 3 12:46:14 2017 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/7b1857d8/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
index c73240c..3c40bc2 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActorTest.java
@@ -172,7 +172,7 @@ public class AkkaRpcActorTest extends TestLogger {
 	 * @throws ExecutionException
 	 * @throws InterruptedException
 	 */
-	@Test(timeout=1000)
+	@Test(timeout=5000)
 	public void testRpcEndpointTerminationFuture() throws Exception {
 		final DummyRpcEndpoint rpcEndpoint = new DummyRpcEndpoint(akkaRpcService);
 		rpcEndpoint.start();