[FLINK-23559][tests] Randomize periodic materialisation interval in t…

…ests
rxp90 · Feb 14, 2022 · 6eeb7e1 · 6eeb7e1
1 parent a2c5f48
commit 6eeb7e1
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java b/...flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
@@ -131,6 +131,15 @@ private static void randomizeConfiguration(MiniCluster miniCluster, Configuratio
  boolean enabled =
  randomize(conf, StateChangelogOptions.ENABLE_STATE_CHANGE_LOG, true, false);
  if (enabled) {
+ randomize(
+ conf,
+ StateChangelogOptions.PERIODIC_MATERIALIZATION_INTERVAL,
+ Duration.ofMillis(100),
+ Duration.ofMillis(500),
+ Duration.ofSeconds(1),
+ Duration.ofSeconds(5),
+ Duration.ofSeconds(
+ Long.MAX_VALUE / 1000 /* max allowed by Duration.toMillis */));
  miniCluster.overrideRestoreModeForRandomizedChangelogStateBackend();
  }
  }