flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [27/27] flink git commit: [FLINK-3755] Extended EventTimeWindowCheckpointITCase to test the boundaries of maxParallelism.
Date Wed, 31 Aug 2016 17:28:45 GMT
[FLINK-3755] Extended EventTimeWindowCheckpointITCase to test the boundaries of maxParallelism.


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

Branch: refs/heads/master
Commit: f7ef82b38ce9361b7d705199d71ac684ba4a76c3
Parents: f44b57c
Author: Stefan Richter <s.richter@data-artisans.com>
Authored: Tue Aug 30 14:59:12 2016 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Wed Aug 31 19:10:02 2016 +0200

----------------------------------------------------------------------
 .../EventTimeWindowCheckpointingITCase.java             | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f7ef82b3/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java
index 9f8ab90..fa5339d 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java
@@ -196,7 +196,16 @@ public class EventTimeWindowCheckpointingITCase extends TestLogger {
 	}
 
 	@Test
-	public void testTumblingTimeWindowWithKVState() {
+	public void testTumblingTimeWindowWithKVStateMinMaxParallelism() {
+		doTestTumblingTimeWindowWithKVState(PARALLELISM);
+	}
+
+	@Test
+	public void testTumblingTimeWindowWithKVStateMaxMaxParallelism() {
+		doTestTumblingTimeWindowWithKVState(1 << 15);
+	}
+
+	public void doTestTumblingTimeWindowWithKVState(int maxParallelism) {
 		final int NUM_ELEMENTS_PER_KEY = 3000;
 		final int WINDOW_SIZE = 100;
 		final int NUM_KEYS = 100;
@@ -207,6 +216,7 @@ public class EventTimeWindowCheckpointingITCase extends TestLogger {
 					"localhost", cluster.getLeaderRPCPort());
 
 			env.setParallelism(PARALLELISM);
+			env.setMaxParallelism(maxParallelism);
 			env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
 			env.enableCheckpointing(100);
 			env.setRestartStrategy(RestartStrategies.fixedDelayRestart(3, 0));


Mime
View raw message