[ https://issues.apache.org/jira/browse/FLINK-10085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579390#comment-16579390 ]
ASF GitHub Bot commented on FLINK-10085: ---------------------------------------- zentol closed pull request #6511: [FLINK-10085][tests] Update AbstractOperatorRestoreTestBase for 1.5 URL: https://github.com/apache/flink/pull/6511 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): 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 36301dfd77f..0e582694362 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 @@ @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 6c9767d011e..74b2086c842 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 @@ @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 00000000000..f606c021692 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 00000000000..fedfe0b38f9 Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.5/_metadata differ ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > Update AbstractOperatorRestoreTestBase > -------------------------------------- > > Key: FLINK-10085 > URL: https://issues.apache.org/jira/browse/FLINK-10085 > Project: Flink > Issue Type: Sub-task > Components: State Backends, Checkpointing, Streaming, Tests > Affects Versions: 1.6.0 > Reporter: Chesnay Schepler > Assignee: Chesnay Schepler > Priority: Critical > Labels: pull-request-available > Fix For: 1.6.1, 1.7.0 > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)