You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2021/02/22 02:30:12 UTC

[flink] 12/13: [FLINK-20536][tests] Update migration tests of StatefulJobSavepointMigrationITCase (Scala version) to cover migration from 1.12

This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 1faa8a03ab7772e77ab7c3377c7fcd44cc4f567d
Author: Dian Fu <di...@apache.org>
AuthorDate: Sat Feb 20 14:10:51 2021 +0800

    [FLINK-20536][tests] Update migration tests of StatefulJobSavepointMigrationITCase (Scala version) to cover migration from 1.12
---
 .../_metadata                                           | Bin 0 -> 41436 bytes
 .../_metadata                                           | Bin 0 -> 41436 bytes
 .../migration/StatefulJobSavepointMigrationITCase.scala |   4 +++-
 3 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.12-jobmanager-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.12-jobmanager-savepoint/_metadata
new file mode 100644
index 0000000..128a5f2
Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.12-jobmanager-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.12-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.12-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..dd2ef62
Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala-udf-migration-itcase-flink1.12-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala
index 05af3a8..28cef3b 100644
--- a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala
+++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala
@@ -66,7 +66,9 @@ object StatefulJobSavepointMigrationITCase {
       (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,