Repository: flink Updated Branches: refs/heads/master 2a1a9c1e3 -> 72f18dc71
[FLINK-5402] [tests] Increase JUnit timeouts in AkkaRpcServiceTest This closes #3430. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/72f18dc7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/72f18dc7 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/72f18dc7 Branch: refs/heads/master Commit: 72f18dc7181b174b2c4adb1561f3689fde1151b1 Parents: b59c14e Author: Ufuk Celebi <[email protected]> Authored: Wed Mar 1 16:14:16 2017 +0100 Committer: Ufuk Celebi <[email protected]> Committed: Wed Mar 1 16:14:40 2017 +0100 ---------------------------------------------------------------------- .../apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/72f18dc7/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java index caacfa8..46359da 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java @@ -135,7 +135,7 @@ public class AkkaRpcServiceTest extends TestLogger { * @throws ExecutionException * @throws InterruptedException */ - @Test(timeout = 1000) + @Test(timeout = 60000) public void testTerminationFuture() throws ExecutionException, InterruptedException { final ActorSystem actorSystem = AkkaUtils.createDefaultActorSystem(); final AkkaRpcService rpcService = new AkkaRpcService(actorSystem, Time.milliseconds(1000)); @@ -160,7 +160,7 @@ public class AkkaRpcServiceTest extends TestLogger { * Tests a simple scheduled runnable being executed by the RPC services scheduled executor * service. */ - @Test(timeout = 1000) + @Test(timeout = 60000) public void testScheduledExecutorServiceSimpleSchedule() throws ExecutionException, InterruptedException { ScheduledExecutor scheduledExecutor = akkaRpcService.getScheduledExecutor(); @@ -186,7 +186,7 @@ public class AkkaRpcServiceTest extends TestLogger { * Tests that the RPC service's scheduled executor service can execute runnables at a fixed * rate. */ - @Test(timeout = 1000) + @Test(timeout = 60000) public void testScheduledExecutorServicePeriodicSchedule() throws ExecutionException, InterruptedException { ScheduledExecutor scheduledExecutor = akkaRpcService.getScheduledExecutor(); @@ -226,7 +226,7 @@ public class AkkaRpcServiceTest extends TestLogger { * Tests that the RPC service's scheduled executor service can execute runnable with a fixed * delay. */ - @Test(timeout = 1000) + @Test(timeout = 60000) public void testScheduledExecutorServiceWithFixedDelaySchedule() throws ExecutionException, InterruptedException { ScheduledExecutor scheduledExecutor = akkaRpcService.getScheduledExecutor();
