flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [FLINK-3453] [runtime] Fix TaskManagerTest stability
Date Sat, 20 Feb 2016 21:55:24 GMT
Repository: flink
Updated Branches:
  refs/heads/master 60d65ce74 -> 9691d9524


[FLINK-3453] [runtime] Fix TaskManagerTest stability


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

Branch: refs/heads/master
Commit: 9691d95244eb143db2e61955c5784293b3ab6b84
Parents: 60d65ce
Author: Ufuk Celebi <uce@apache.org>
Authored: Sat Feb 20 22:45:26 2016 +0100
Committer: Ufuk Celebi <uce@apache.org>
Committed: Sat Feb 20 22:45:26 2016 +0100

----------------------------------------------------------------------
 .../flink/runtime/taskmanager/TaskManagerTest.java     | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/9691d952/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
index cccd325..b9f4cbf 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
@@ -102,7 +102,7 @@ public class TaskManagerTest extends TestLogger {
 
 	private static final FiniteDuration timeout = new FiniteDuration(1, TimeUnit.MINUTES);
 
-	private static final FiniteDuration d = new FiniteDuration(20, TimeUnit.SECONDS);
+	private static final FiniteDuration d = new FiniteDuration(60, TimeUnit.SECONDS);
 
 	private static ActorSystem system;
 
@@ -1079,16 +1079,17 @@ public class TaskManagerTest extends TestLogger {
 						Collections.<URL>emptyList(),
 						0);
 
-				// Make sure to register
-				Future<?> connectFuture = taskManager.ask(new TestingTaskManagerMessages
-						.NotifyWhenRegisteredAtJobManager(jobManager.actor()), remaining());
-				Await.ready(connectFuture, remaining());
-
 				// Submit the task
 				new Within(d) {
+
 					@Override
 					protected void run() {
 						try {
+							// Make sure to register
+							Future<?> connectFuture = taskManager.ask(new TestingTaskManagerMessages
+									.NotifyWhenRegisteredAtJobManager(jobManager.actor()), remaining());
+							Await.ready(connectFuture, remaining());
+
 							Future<Object> taskRunningFuture = taskManager.ask(
 									new TestingTaskManagerMessages.NotifyWhenTaskIsRunning(
 											tdd.getExecutionId()), timeout);


Mime
View raw message