You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by hx...@apache.org on 2022/10/31 08:00:35 UTC
[flink] 09/14: [release] Upgrade current version to 1.16 for AbstractOperatorRestoreTestBase and create snapshots
This is an automated email from the ASF dual-hosted git repository.
hxb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6df1ef6d0911c2d5c80827f36877cda7a6c7bc16
Author: huangxingbo <hx...@apache.org>
AuthorDate: Fri Oct 28 11:51:26 2022 +0800
[release] Upgrade current version to 1.16 for AbstractOperatorRestoreTestBase and create snapshots
---
.../keyed/AbstractKeyedOperatorRestoreTestBase.java | 2 +-
.../AbstractNonKeyedOperatorRestoreTestBase.java | 2 +-
.../operatorstate/complexKeyed-flink1.16/_metadata | Bin 0 -> 13772 bytes
.../operatorstate/nonKeyed-flink1.16/_metadata | Bin 0 -> 3693 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 511829c41ce..6742188ac98 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_3, FlinkVersion.v1_15);
+ return FlinkVersion.rangeOf(FlinkVersion.v1_3, FlinkVersion.v1_16);
}
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 ba2da3a1ded..ba7a8497ba8 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_3, FlinkVersion.v1_15);
+ return FlinkVersion.rangeOf(FlinkVersion.v1_3, FlinkVersion.v1_16);
}
protected AbstractNonKeyedOperatorRestoreTestBase(FlinkVersion flinkVersion) {
diff --git a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.16/_metadata b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.16/_metadata
new file mode 100644
index 00000000000..216268e0c6d
Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.16/_metadata differ
diff --git a/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.16/_metadata b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.16/_metadata
new file mode 100644
index 00000000000..17e95d39e0d
Binary files /dev/null and b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.16/_metadata differ