You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2019/06/20 08:56:42 UTC

[flink] 09/11: [FLINK-11768] Update TypeSerializerSnapshotMigrationITCase for Flink 1.8

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

tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit dd04f3ea0a8bf2facd8ebf81f06a209b7f521c70
Author: yanghua <ya...@gmail.com>
AuthorDate: Sun Apr 14 13:24:58 2019 +0800

    [FLINK-11768] Update TypeSerializerSnapshotMigrationITCase for Flink 1.8
---
 .../migration/TypeSerializerSnapshotMigrationITCase.java |   4 +++-
 .../_metadata                                            | Bin 0 -> 1358 bytes
 .../_metadata                                            | Bin 0 -> 1257 bytes
 3 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
index 58fe908..509f3b7 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/migration/TypeSerializerSnapshotMigrationITCase.java
@@ -88,7 +88,9 @@ public class TypeSerializerSnapshotMigrationITCase extends SavepointMigrationTes
 			Tuple2.of(MigrationVersion.v1_6, StateBackendLoader.MEMORY_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));
+			Tuple2.of(MigrationVersion.v1_7, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME),
+			Tuple2.of(MigrationVersion.v1_8, StateBackendLoader.MEMORY_STATE_BACKEND_NAME),
+			Tuple2.of(MigrationVersion.v1_8, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME));
 	}
 
 	private final MigrationVersion testMigrateVersion;
diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.8-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.8-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..7ff30c5
Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.8-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.8-savepoint/_metadata b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.8-savepoint/_metadata
new file mode 100644
index 0000000..1f50d35
Binary files /dev/null and b/flink-tests/src/test/resources/type-serializer-snapshot-migration-itcase-flink1.8-savepoint/_metadata differ