You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/09/06 14:14:44 UTC
[flink] branch master updated: [FLINK-13624][Tests] Update
StatefulJobWBroadcastStateMigrationITCase to restore from 1.9 savepoint
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 <ya...@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