You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/08/14 08:03:37 UTC
[flink] branch master updated: [FLINK-10085][tests] Update
AbstractOperatorRestoreTestBase for 1.6
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 2dd289f [FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.6
2dd289f is described below
commit 2dd289f3f3e91b9747908d282e075b8acac32fbe
Author: zentol <ch...@apache.org>
AuthorDate: Tue Aug 7 11:36:04 2018 +0200
[FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.6
---
.../keyed/AbstractKeyedOperatorRestoreTestBase.java | 2 +-
.../AbstractNonKeyedOperatorRestoreTestBase.java | 2 +-
.../operatorstate/complexKeyed-flink1.5/_metadata | Bin 0 -> 267378 bytes
.../operatorstate/nonKeyed-flink1.5/_metadata | Bin 0 -> 6224 bytes
4 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
index 36301df..0e58269 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/keyed/AbstractKeyedOperatorRestoreTestBase.java
@@ -41,7 +41,7 @@ public abstract class AbstractKeyedOperatorRestoreTestBase extends AbstractOpera
@Parameterized.Parameters(name = "Migrate Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
- return Arrays.asList(MigrationVersion.v1_2, MigrationVersion.v1_3, MigrationVersion.v1_4);
+ return Arrays.asList(MigrationVersion.v1_2, MigrationVersion.v1_3, MigrationVersion.v1_4, MigrationVersion.v1_5);
}
public AbstractKeyedOperatorRestoreTestBase(MigrationVersion migrationVersion) {
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
index 6c9767d..74b2086 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/AbstractNonKeyedOperatorRestoreTestBase.java
@@ -47,7 +47,7 @@ public abstract class AbstractNonKeyedOperatorRestoreTestBase extends AbstractOp
@Parameterized.Parameters(name = "Migrate Savepoint: {0}")
public static Collection<MigrationVersion> parameters () {
- return Arrays.asList(MigrationVersion.v1_2, MigrationVersion.v1_3, MigrationVersion.v1_4);
+ return Arrays.asList(MigrationVersion.v1_2, MigrationVersion.v1_3, MigrationVersion.v1_4, MigrationVersion.v1_5);
}
protected AbstractNonKeyedOperatorRestoreTestBase(MigrationVersion migrationVersion) {
diff --git a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.5/_metadata b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.5/_metadata
new file mode 100644
index 0000000..f606c02
Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.5/_metadata differ
diff --git a/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.5/_metadata b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.5/_metadata
new file mode 100644
index 0000000..fedfe0b
Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.5/_metadata differ