You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2016/08/31 17:28:45 UTC
[27/27] flink git commit: [FLINK-3755] Extended
EventTimeWindowCheckpointITCase to test the boundaries of maxParallelism.
[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....@data-artisans.com>
Authored: Tue Aug 30 14:59:12 2016 +0200
Committer: Aljoscha Krettek <al...@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));