This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 369088f0f94ae7732f8a65b6676f2187c871328a Author: Roman Khachatryan <khachatryan.ro...@gmail.com> AuthorDate: Tue Feb 15 22:45:13 2022 +0100 [hotfix][tests] Explicitly disable changelog in migration tests --- .../checkpointing/utils/LegacyStatefulJobSavepointMigrationITCase.java | 1 + .../test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java | 1 + .../checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java | 1 + .../flink/test/migration/TypeSerializerSnapshotMigrationITCase.java | 1 + .../test/state/operator/restore/AbstractOperatorRestoreTestBase.java | 1 + .../api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala | 2 ++ 6 files changed, 7 insertions(+) diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/LegacyStatefulJobSavepointMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/LegacyStatefulJobSavepointMigrationITCase.java index 6ac2d98..e59be25 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/LegacyStatefulJobSavepointMigrationITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/LegacyStatefulJobSavepointMigrationITCase.java @@ -168,6 +168,7 @@ public class LegacyStatefulJobSavepointMigrationITCase extends SavepointMigratio default: throw new UnsupportedOperationException(); } + env.enableChangelogStateBackend(false); env.enableCheckpointing(500); env.setParallelism(4); diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java index 007be6a..260c1f2 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java @@ -133,6 +133,7 @@ public class StatefulJobSavepointMigrationITCase extends SavepointMigrationTestB env.enableCheckpointing(500); env.setParallelism(parallelism); env.setMaxParallelism(parallelism); + env.enableChangelogStateBackend(false); SourceFunction<Tuple2<Long, Long>> nonParallelSource; SourceFunction<Tuple2<Long, Long>> parallelSource; diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java index 35c7257..4470b85 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java @@ -113,6 +113,7 @@ public class StatefulJobWBroadcastStateMigrationITCase extends SavepointMigratio default: throw new UnsupportedOperationException(); } + env.enableChangelogStateBackend(false); env.enableCheckpointing(500); env.setParallelism(parallelism); diff --git a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java index c9e59db..aa22407 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java @@ -130,6 +130,7 @@ public class TypeSerializerSnapshotMigrationITCase extends SavepointMigrationTes default: throw new UnsupportedOperationException(); } + env.enableChangelogStateBackend(false); env.enableCheckpointing(500); env.setParallelism(parallelism); diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java index f5bbff4..0ddf11e 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java @@ -214,6 +214,7 @@ public abstract class AbstractOperatorRestoreTestBase extends TestLogger { env.enableCheckpointing(500, CheckpointingMode.EXACTLY_ONCE); env.setRestartStrategy(RestartStrategies.noRestart()); env.setStateBackend((StateBackend) new MemoryStateBackend()); + env.enableChangelogStateBackend(false); switch (mode) { case MIGRATE: diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala index 7212a6a..78e646e 100644 --- a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala +++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala @@ -110,6 +110,7 @@ class StatefulJobWBroadcastStateMigrationITCase( env.setStateBackend(new HashMapStateBackend()) case _ => throw new UnsupportedOperationException } + env.enableChangelogStateBackend(false) lazy val firstBroadcastStateDesc = new MapStateDescriptor[Long, Long]( "broadcast-state-1", @@ -179,6 +180,7 @@ class StatefulJobWBroadcastStateMigrationITCase( env.setStateBackend(new HashMapStateBackend()) case _ => throw new UnsupportedOperationException } + env.enableChangelogStateBackend(false) lazy val firstBroadcastStateDesc = new MapStateDescriptor[Long, Long]( "broadcast-state-1",