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 <h...@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
