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

…tateMigrationITCase (Scala version) to cover migration from 1.12
mbalassi · Feb 22, 2021 · 7f4e707 · 7f4e707
1 parent 099b394
commit 7f4e707
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/...ateful-scala-with-broadcast-udf-migration-itcase-flink1.12-jobmanager-savepoint/_metadata b/...ateful-scala-with-broadcast-udf-migration-itcase-flink1.12-jobmanager-savepoint/_metadata
diff --git a/.../stateful-scala-with-broadcast-udf-migration-itcase-flink1.12-rocksdb-savepoint/_metadata b/.../stateful-scala-with-broadcast-udf-migration-itcase-flink1.12-rocksdb-savepoint/_metadata
diff --git a/...cala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala b/...cala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala
@@ -66,7 +66,9 @@ object StatefulJobWBroadcastStateMigrationITCase {
  (MigrationVersion.v1_10, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
  (MigrationVersion.v1_10, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
  (MigrationVersion.v1_11, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- (MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
+ (MigrationVersion.v1_11, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_12, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_12, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
  }
 
  // TODO to generate savepoints for a specific Flink version / backend type,