[hotfix][tests] Explicitly disable changelog in migration tests

rxp90 · Feb 16, 2022 · 369088f · 369088f
1 parent 20e03f4
commit 369088f
Show file tree

Hide file tree

Showing 6 changed files with 7 additions and 0 deletions.
diff --git a/.../org/apache/flink/test/checkpointing/utils/LegacyStatefulJobSavepointMigrationITCase.java b/.../org/apache/flink/test/checkpointing/utils/LegacyStatefulJobSavepointMigrationITCase.java
@@ -168,6 +168,7 @@ public void testSavepointRestore() throws Exception {
  default:
  throw new UnsupportedOperationException();
  }
+ env.enableChangelogStateBackend(false);
 
  env.enableCheckpointing(500);
  env.setParallelism(4);

diff --git a/...t/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java b/...t/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
@@ -133,6 +133,7 @@ public void testSavepoint() throws Exception {
  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/.../org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java b/.../org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
@@ -113,6 +113,7 @@ public void testSavepoint() throws Exception {
  default:
  throw new UnsupportedOperationException();
  }
+ env.enableChangelogStateBackend(false);
 
  env.enableCheckpointing(500);
  env.setParallelism(parallelism);

diff --git a/.../src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java b/.../src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
@@ -130,6 +130,7 @@ public void testSavepoint() throws Exception {
  default:
  throw new UnsupportedOperationException();
  }
+ env.enableChangelogStateBackend(false);
 
  env.enableCheckpointing(500);
  env.setParallelism(parallelism);

diff --git a/...st/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java b/...st/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
@@ -214,6 +214,7 @@ private JobGraph createJobGraph(ExecutionMode mode) {
  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/...cala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala b/...cala/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",