[FLINK-18552][tests] Update migration tests of StatefulJobWBroadcastS…

…tateMigrationITCase (Java version) to cover migration from 1.10
spotify · Jul 24, 2020 · 8889cdc · 8889cdc
1 parent 1af75f5
commit 8889cdc
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/.../org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java b/.../org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
@@ -72,7 +72,9 @@ public static Collection<Tuple2<MigrationVersion, String>> parameters () {
  Tuple2.of(MigrationVersion.v1_8, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
  Tuple2.of(MigrationVersion.v1_8, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
  Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_9, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_10, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
  }
 
  private final MigrationVersion testMigrateVersion;

diff --git a/...sources/new-stateful-broadcast-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata b/...sources/new-stateful-broadcast-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
diff --git a/.../test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.10-savepoint/_metadata b/.../test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.10-savepoint/_metadata