This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 2bae85e [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint 2bae85e is described below commit 2bae85ed34a04c15a235a700de4649024dcf61d9 Author: yanghua <yanghua1...@gmail.com> AuthorDate: Thu Sep 5 16:02:20 2019 +0800 [FLINK-13624][Tests] Update StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint This closes #9626. --- .../_metadata | Bin 0 -> 51942 bytes .../_metadata | Bin 0 -> 51942 bytes .../StatefulJobWBroadcastStateMigrationITCase.scala | 6 ++++-- 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-jobmanager-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-jobmanager-savepoint/_metadata new file mode 100644 index 0000000..8ffcb37 Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-jobmanager-savepoint/_metadata differ diff --git a/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata new file mode 100644 index 0000000..5f20171 Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-with-broadcast-udf-migration-itcase-flink1.9-rocksdb-savepoint/_metadata differ diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala index 822ff9a..4acfa78 100644 --- a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala +++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobWBroadcastStateMigrationITCase.scala @@ -60,14 +60,16 @@ object StatefulJobWBroadcastStateMigrationITCase { (MigrationVersion.v1_7, StateBackendLoader.MEMORY_STATE_BACKEND_NAME), (MigrationVersion.v1_7, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME), (MigrationVersion.v1_8, StateBackendLoader.MEMORY_STATE_BACKEND_NAME), - (MigrationVersion.v1_8, StateBackendLoader.ROCKSDB_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)) } // 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) // TODO Note: You should generate the savepoint based on the release branch instead of the master. - val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_8 + val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_9 val GENERATE_SAVEPOINT_BACKEND_TYPE: String = StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME val NUM_ELEMENTS = 4