[FLINK-10780][tests] Update Java / Scala StatefulJobWBroadcastStateMi…

…grationITCase for 1.7
bbejeck · Jan 2, 2019 · 7bb63f6 · 7bb63f6
1 parent 50f4196
commit 7bb63f6
Show file tree

Hide file tree

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

diff --git a/...esources/new-stateful-broadcast-udf-migration-itcase-flink1.7-rocksdb-savepoint/_metadata b/...esources/new-stateful-broadcast-udf-migration-itcase-flink1.7-rocksdb-savepoint/_metadata
diff --git a/...c/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.7-savepoint/_metadata b/...c/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.7-savepoint/_metadata
diff --git a/...tateful-scala-with-broadcast-udf-migration-itcase-flink1.7-jobmanager-savepoint/_metadata b/...tateful-scala-with-broadcast-udf-migration-itcase-flink1.7-jobmanager-savepoint/_metadata
diff --git a/...s/stateful-scala-with-broadcast-udf-migration-itcase-flink1.7-rocksdb-savepoint/_metadata b/...s/stateful-scala-with-broadcast-udf-migration-itcase-flink1.7-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
@@ -56,13 +56,15 @@ object StatefulJobWBroadcastStateMigrationITCase {
  (MigrationVersion.v1_5, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
  (MigrationVersion.v1_5, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
  (MigrationVersion.v1_6, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
- (MigrationVersion.v1_6, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
+ (MigrationVersion.v1_6, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_7, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+ (MigrationVersion.v1_7, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME))
  }
 
  // TODO to generate savepoints for a specific Flink version / backend type,
  // TODO change these values accordingly, e.g. to generate for 1.3 with RocksDB,
  // TODO set as (MigrationVersion.v1_3, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME)
- val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_6
+ val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_7
  val GENERATE_SAVEPOINT_BACKEND_TYPE: String = StateBackendLoader.MEMORY_STATE_BACKEND_NAME
 
  val NUM_ELEMENTS = 4