From a79916b88ef3d97c11980c25d3887d43964c152d Mon Sep 17 00:00:00 2001 From: "Tzu-Li (Gordon) Tai" Date: Wed, 31 Jan 2018 11:13:00 +0100 Subject: [PATCH] [FLINK-8421] [test] Increase MAX_MEM_STATE_SIZE and Akka framesize in AbstractEventTimeWindowCheckpointingITCase After adding the TypeSerializerConfigSnapshots of timer serializers to the timers snapshots, the size of the timer snapshots have potentially doubled. This caused the AbstractEventTimeWindowCheckpointingITCase to be failing, because the configured max memory state size and Akka framesize were too small. This commit doubles those sizes. This closes #5362. --- .../AbstractEventTimeWindowCheckpointingITCase.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java index 829ac93843596..53d329b1e0242 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java @@ -25,6 +25,7 @@ import org.apache.flink.api.java.tuple.Tuple; import org.apache.flink.api.java.tuple.Tuple2; import org.apache.flink.api.java.tuple.Tuple4; +import org.apache.flink.configuration.AkkaOptions; import org.apache.flink.configuration.ConfigConstants; import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.HighAvailabilityOptions; @@ -87,7 +88,7 @@ @SuppressWarnings("serial") public abstract class AbstractEventTimeWindowCheckpointingITCase extends TestLogger { - private static final int MAX_MEM_STATE_SIZE = 10 * 1024 * 1024; + private static final int MAX_MEM_STATE_SIZE = 20 * 1024 * 1024; private static final int PARALLELISM = 4; private static LocalFlinkMiniCluster cluster; @@ -137,6 +138,7 @@ public void startTestCluster() throws Exception { config.setLong(TaskManagerOptions.MANAGED_MEMORY_SIZE, 48L); // the default network buffers size (10% of heap max =~ 150MB) seems to much for this test case config.setLong(TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MAX, 80L << 20); // 80 MB + config.setString(AkkaOptions.FRAMESIZE, String.valueOf(MAX_MEM_STATE_SIZE) + "b"); if (zkServer != null) { config.setString(HighAvailabilityOptions.HA_MODE, "ZOOKEEPER");