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 2018/02/06 19:03:03 UTC
[03/28] flink git commit: [FLINK-8472] [DataStream,
test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4
[FLINK-8472] [DataStream, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/83b9727d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/83b9727d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/83b9727d
Branch: refs/heads/release-1.4
Commit: 83b9727dcc9e3c60b2caee147562003e48821908
Parents: 2ada856
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
Authored: Thu Jan 25 18:37:05 2018 +0100
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Tue Feb 6 17:31:32 2018 +0100
----------------------------------------------------------------------
.../utils/StatefulJobSavepointMigrationITCase.java | 6 ++++--
.../_metadata | Bin 0 -> 32810 bytes
.../_metadata | Bin 0 -> 32738 bytes
3 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/83b9727d/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
index 28f7e4b..641e450b 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobSavepointMigrationITCase.java
@@ -73,7 +73,9 @@ public class StatefulJobSavepointMigrationITCase extends SavepointMigrationTestB
Tuple2.of(MigrationVersion.v1_2, AbstractStateBackend.MEMORY_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_2, AbstractStateBackend.ROCKSDB_STATE_BACKEND_NAME),
Tuple2.of(MigrationVersion.v1_3, AbstractStateBackend.MEMORY_STATE_BACKEND_NAME),
- Tuple2.of(MigrationVersion.v1_3, AbstractStateBackend.ROCKSDB_STATE_BACKEND_NAME));
+ Tuple2.of(MigrationVersion.v1_3, AbstractStateBackend.ROCKSDB_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_4, AbstractStateBackend.MEMORY_STATE_BACKEND_NAME),
+ Tuple2.of(MigrationVersion.v1_4, AbstractStateBackend.ROCKSDB_STATE_BACKEND_NAME));
}
/**
@@ -81,7 +83,7 @@ public class StatefulJobSavepointMigrationITCase extends SavepointMigrationTestB
* TODO change these values accordingly, e.g. to generate for 1.3 with RocksDB,
* TODO set as (MigrationVersion.v1_3, AbstractStateBackend.ROCKSDB_STATE_BACKEND_NAME)
*/
- private final MigrationVersion flinkGenerateSavepointVersion = MigrationVersion.v1_3;
+ private final MigrationVersion flinkGenerateSavepointVersion = MigrationVersion.v1_4;
private final String flinkGenerateSavepointBackendType = AbstractStateBackend.ROCKSDB_STATE_BACKEND_NAME;
private final MigrationVersion testMigrateVersion;
http://git-wip-us.apache.org/repos/asf/flink/blob/83b9727d/flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata
new file mode 100644
index 0000000..61a2549
Binary files /dev/null and b/flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata differ
http://git-wip-us.apache.org/repos/asf/flink/blob/83b9727d/flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-savepoint/_metadata
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-savepoint/_metadata b/flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-savepoint/_metadata
new file mode 100644
index 0000000..5e760c2
Binary files /dev/null and b/flink-tests/src/test/resources/stateful-udf-migration-itcase-flink1.4-savepoint/_metadata differ