You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gy...@apache.org on 2015/03/11 01:23:13 UTC
[3/5] flink git commit: [FLINK-1660] [streaming] Increased timeout
for MultiTriggerPolicyTest and introduced a constant representing it.
[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) <jo...@s-traub.com>
Authored: Tue Mar 10 09:20:04 2015 +0100
Committer: Gyula Fora <gy...@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) {