Skip to content

Commit

Permalink
[FLINK-8421] [test] Increase MAX_MEM_STATE_SIZE and Akka framesize in…
Browse files Browse the repository at this point in the history
… 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 apache#5362.
  • Loading branch information
tzulitai committed Feb 6, 2018
1 parent 0752813 commit a79916b
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;
Expand Down Expand Up @@ -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");
Expand Down

0 comments on commit a79916b

Please sign in to comment.