diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/SnapshotMigrationTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/SnapshotMigrationTestBase.java index c08951688d599..92c38ca3c6e88 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/SnapshotMigrationTestBase.java +++ b/flink-tests/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();