Revert "[FLINK-29788][state] Disable changelog temporally when Snapsh…

…otMigrationTestBase triggers native savepoint" This reverts commit c89e400
aiven · Feb 22, 2024 · d03629d · d03629d
1 parent 49d2daf
commit d03629d
Showing 1 changed file with 0 additions and 5 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
@@ -267,11 +267,6 @@ 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();