Skip to content

Commit bd3a6cb

Browse files
committed
[FLINK-38541][checkpoint] Randomize UNALIGNED_DURING_RECOVERY_ENABLED for testing
1 parent 884e214 commit bd3a6cb

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -148,6 +148,7 @@ private static void randomizeConfiguration(MiniCluster miniCluster, Configuratio
148148
randomize(conf, CheckpointingOptions.ENABLE_UNALIGNED, true, false);
149149
randomize(
150150
conf, CheckpointingOptions.UNALIGNED_RECOVER_OUTPUT_ON_DOWNSTREAM, true, false);
151+
randomize(conf, CheckpointingOptions.UNALIGNED_DURING_RECOVERY_ENABLED, true, false);
151152
randomize(
152153
conf,
153154
CheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT,

0 commit comments

Comments
 (0)