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

…grationITCase to cover migration till release-1.11
spotify · Jul 13, 2020 · bcbeedf · bcbeedf
1 parent 08e2049
commit bcbeedf
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 1 deletion.
diff --git a/...st/resources/stateful-scala-udf-migration-itcase-flink1.10-jobmanager-savepoint/_metadata b/...st/resources/stateful-scala-udf-migration-itcase-flink1.10-jobmanager-savepoint/_metadata
diff --git a/.../test/resources/stateful-scala-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata b/.../test/resources/stateful-scala-udf-migration-itcase-flink1.10-rocksdb-savepoint/_metadata
diff --git a/...st/resources/stateful-scala-udf-migration-itcase-flink1.11-jobmanager-savepoint/_metadata b/...st/resources/stateful-scala-udf-migration-itcase-flink1.11-jobmanager-savepoint/_metadata
diff --git a/.../test/resources/stateful-scala-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata b/.../test/resources/stateful-scala-udf-migration-itcase-flink1.11-rocksdb-savepoint/_metadata
diff --git a/...test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala b/...test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala
@@ -62,7 +62,11 @@ object StatefulJobSavepointMigrationITCase {
  (MigrationVersion.v1_8, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
  (MigrationVersion.v1_8, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
  (MigrationVersion.v1_9, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- (MigrationVersion.v1_9, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
+ (MigrationVersion.v1_9, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ (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))
  }
 
  // TODO to generate savepoints for a specific Flink version / backend type,