This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit e60fb06aa15f9e7db9816ff1c7f40c34548c8418 Author: Matthias Pohl <[email protected]> AuthorDate: Thu Mar 23 19:01:05 2023 +0100 [FLINK-31593][tests] Adds 1.17.0 reference data for AbstractOperatorRestoreTestBase-related tests based on release-1.17.0 --- .../keyed/AbstractKeyedOperatorRestoreTestBase.java | 2 +- .../AbstractNonKeyedOperatorRestoreTestBase.java | 2 +- .../operatorstate/complexKeyed-flink1.17/_metadata | Bin 0 -> 14517 bytes .../operatorstate/nonKeyed-flink1.17/_metadata | Bin 0 -> 4438 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 ef3b4b69273..6f63d3e3b2c 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 @@ -38,7 +38,7 @@ public abstract class AbstractKeyedOperatorRestoreTestBase extends AbstractOpera @Parameterized.Parameters(name = "Migrate Savepoint: {0}") public static Collection<FlinkVersion> parameters() { - return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_16); + return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_17); } public AbstractKeyedOperatorRestoreTestBase(FlinkVersion flinkVersion) { 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 9a2a0c414d1..26a68d92dae 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 @@ -45,7 +45,7 @@ public abstract class AbstractNonKeyedOperatorRestoreTestBase @Parameterized.Parameters(name = "Migrate Savepoint: {0}") public static Collection<FlinkVersion> parameters() { - return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_16); + return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_17); } protected AbstractNonKeyedOperatorRestoreTestBase(FlinkVersion flinkVersion) { diff --git a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.17/_metadata b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.17/_metadata new file mode 100644 index 00000000000..860ad8410d6 Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.17/_metadata differ diff --git a/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.17/_metadata b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.17/_metadata new file mode 100644 index 00000000000..ac00ada7753 Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.17/_metadata differ
