This is an automated email from the ASF dual-hosted git repository. hxb pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit c89e400ae379c8b7490d9af20f82f49319895dce Author: Hangxiang Yu <[email protected]> AuthorDate: Mon Oct 31 14:07:06 2022 +0800 [FLINK-29788][state] Disable changelog temporally when SnapshotMigrationTestBase triggers native savepoint This closes #21196. --- .../flink/test/checkpointing/utils/SnapshotMigrationTestBase.java | 5 +++++ 1 file changed, 5 insertions(+) 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 3e5e7662405..a46b51002f4 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 @@ -269,6 +269,11 @@ public abstract class SnapshotMigrationTestBase extends TestLogger { 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();
