(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 release-1.18
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 5e40a556011949bd84d401d3161f4007beb56bce
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 86da4b2a66f..b29376b6f26 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
@@ -19,6 +19,7 @@
 package org.apache.flink.streaming.util;
 
 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;
@@ -118,6 +119,7 @@ public class TestStreamEnvironment extends 
StreamExecutionEnvironment {
                     Duration.ofSeconds(0),
                     Duration.ofMillis(100),
                     Duration.ofSeconds(2));
+            randomize(conf, ExecutionOptions.SNAPSHOT_COMPRESSION, true, 
false);
         }
 
         // randomize ITTests for enabling state change log