[FLINK-29788][state] Disable changelog temporally when SnapshotMigrat…

…ionTestBase triggers native savepoint This closes apache#21196.
nicusX · Oct 31, 2022 · c89e400 · c89e400
1 parent 6df1ef6
commit c89e400
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...ts/src/test/java/org/apache/flink/test/checkpointing/utils/SnapshotMigrationTestBase.java b/...ts/src/test/java/org/apache/flink/test/checkpointing/utils/SnapshotMigrationTestBase.java
@@ -269,6 +269,11 @@ protected final void executeAndSnapshot(
 
         ClusterClient<?> client = miniClusterResource.getClusterClient();
 
+        // TODO [FLINK-29802] Remove this after ChangelogStateBackend supports native savepoint.
+        if (snapshotType == SnapshotType.SAVEPOINT_NATIVE) {
+            env.enableChangelogStateBackend(false);
+        }
+
         // Submit the job
         JobGraph jobGraph = env.getStreamGraph().getJobGraph();