(flink) 02/05: [FLINK-34063][test-utils] Add ExecutionOptions.SNAPSHOT_COMPRESSION to randomized checkpointing options.

[dmvk]

This is an automated email from the ASF dual-hosted git repository.

dmvk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 006a0869e32f64dbbe0b6d6142fc36bf7544ac5c
Author: David Moravek <d...@apache.org>
AuthorDate: Fri Jan 12 10:45:40 2024 +0100

    [FLINK-34063][test-utils] Add ExecutionOptions.SNAPSHOT_COMPRESSION to 
randomized checkpointing options.
---
 .../java/org/apache/flink/streaming/util/TestStreamEnvironment.java     | 2 ++
 1 file changed, 2 insertions(+)

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 e30035ff021..e8f9f2578f6 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
@@ -20,6 +20,7 @@ package org.apache.flink.streaming.util;
 
 import org.apache.flink.configuration.CheckpointingOptions;
 import org.apache.flink.configuration.Configuration;
+import org.apache.flink.configuration.ExecutionOptions;
 import org.apache.flink.configuration.ReadableConfig;
 import org.apache.flink.configuration.StateChangelogOptions;
 import org.apache.flink.core.fs.Path;
@@ -120,6 +121,7 @@ public class TestStreamEnvironment extends 
StreamExecutionEnvironment {
                     Duration.ofMillis(100),
                     Duration.ofSeconds(2));
             randomize(conf, CheckpointingOptions.CLEANER_PARALLEL_MODE, true, 
false);
+            randomize(conf, ExecutionOptions.SNAPSHOT_COMPRESSION, true, 
false);
         }
 
         // randomize ITTests for enabling state change log