You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2017/03/01 15:15:08 UTC
[1/2] flink git commit: [FLINK-5402] [tests] Increase JUnit timeouts
in AkkaRpcServiceTest
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 <uc...@apache.org>
Authored: Wed Mar 1 16:14:16 2017 +0100
Committer: Ufuk Celebi <uc...@apache.org>
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();
[2/2] flink git commit: [FLINK-5389] [tests] Increate ask timeout in
JobSubmitTest
Posted by uc...@apache.org.
[FLINK-5389] [tests] Increate ask timeout in JobSubmitTest
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b59c14e9
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b59c14e9
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b59c14e9
Branch: refs/heads/master
Commit: b59c14e9ca41b88b51c069891229a68987f86550
Parents: 2a1a9c1
Author: Ufuk Celebi <uc...@apache.org>
Authored: Tue Feb 28 17:40:03 2017 +0100
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Wed Mar 1 16:14:40 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b59c14e9/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
index 529c100..ba5f973 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
@@ -63,7 +63,7 @@ import static org.junit.Assert.fail;
*/
public class JobSubmitTest {
- private static final FiniteDuration timeout = new FiniteDuration(5000, TimeUnit.MILLISECONDS);
+ private static final FiniteDuration timeout = new FiniteDuration(60000, TimeUnit.MILLISECONDS);
private static ActorSystem jobManagerSystem;
private static ActorGateway jmGateway;