This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8bec0ad63852fd6c727ac7f5865bd0d8417357c0 Author: Roman Khachatryan <[email protected]> AuthorDate: Fri Feb 11 14:22:21 2022 +0100 [hotfix][tests] Don't override ChangelogEnable setting from pom.xml --- .../java/org/apache/flink/streaming/util/TestStreamEnvironment.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java index 4bf603c..f201aeb 100644 --- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java +++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java @@ -123,8 +123,10 @@ public class TestStreamEnvironment extends StreamExecutionEnvironment { // 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);
