[hotfix][tests] Don't override ChangelogEnable setting from pom.xml

rxp90 · Feb 14, 2022 · 8bec0ad · 8bec0ad
1 parent 40dc2b4
commit 8bec0ad
Showing 1 changed file with 4 additions and 2 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
@@ -123,8 +123,10 @@ private static void randomizeConfiguration(MiniCluster miniCluster, Configuratio
  // randomize ITTests for enabling state change log
  if (isConfigurationSupportedByChangelog(miniCluster.getConfiguration())) {
  if (STATE_CHANGE_LOG_CONFIG.equalsIgnoreCase(STATE_CHANGE_LOG_CONFIG_ON)) {
- conf.set(StateChangelogOptions.ENABLE_STATE_CHANGE_LOG, true);
- miniCluster.overrideRestoreModeForRandomizedChangelogStateBackend();
+ if (!conf.contains(StateChangelogOptions.ENABLE_STATE_CHANGE_LOG)) {
+ conf.set(StateChangelogOptions.ENABLE_STATE_CHANGE_LOG, true);
+ miniCluster.overrideRestoreModeForRandomizedChangelogStateBackend();
+ }
  } else if (STATE_CHANGE_LOG_CONFIG.equalsIgnoreCase(STATE_CHANGE_LOG_CONFIG_RAND)) {
  boolean enabled =
  randomize(conf, StateChangelogOptions.ENABLE_STATE_CHANGE_LOG, true, false);