flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gyf...@apache.org
Subject [3/5] flink git commit: [FLINK-1660] [streaming] Increased timeout for MultiTriggerPolicyTest and introduced a constant representing it.
Date Wed, 11 Mar 2015 00:23:13 GMT
[FLINK-1660] [streaming] Increased timeout for MultiTriggerPolicyTest and introduced a constant
representing it.


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

Branch: refs/heads/master
Commit: f09c0af2f9a2f7844ccef0983699782c594588ca
Parents: 2bba2b3
Author: Jonas Traub (powibol) <jon@s-traub.com>
Authored: Tue Mar 10 09:20:04 2015 +0100
Committer: Gyula Fora <gyfora@apache.org>
Committed: Tue Mar 10 16:33:43 2015 +0100

----------------------------------------------------------------------
 .../api/windowing/policy/MultiTriggerPolicyTest.java   | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f09c0af2/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/policy/MultiTriggerPolicyTest.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/policy/MultiTriggerPolicyTest.java
b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/policy/MultiTriggerPolicyTest.java
index de6cdcb..9964cd8 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/policy/MultiTriggerPolicyTest.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/windowing/policy/MultiTriggerPolicyTest.java
@@ -31,6 +31,15 @@ import org.junit.Test;
 public class MultiTriggerPolicyTest {
 
 	/**
+	 * This constant defines the timeout for the test of the start ups of the
+	 * active trigger policy Threads.
+	 */
+	private static final int TIMEOUT = 120000;
+
+	// Use this to increase the timeout to be as long as possible.
+	// private static final int TIMEOUT=Integer.MAX_VALUE;
+
+	/**
 	 * This test covers all regular notify call. It takes no fake elements into
 	 * account.
 	 */
@@ -138,8 +147,8 @@ public class MultiTriggerPolicyTest {
 		Runnable runnable = multiTrigger.createActiveTriggerRunnable(cb);
 		new Thread(runnable).start();
 
-		assertTrue("Even after 10000ms not all active policy runnables were started.",
-				cb.check(10000, 1, 2, 3));
+		assertTrue("Even after " + TIMEOUT + "ms not all active policy runnables were started.",
+				cb.check(TIMEOUT, 1, 2, 3));
 	}
 
 	private void arrayEqualityCheck(Object[] array1, Object[] array2) {


Mime
View raw message