[flink] 11/13: [release] Upgrade current version to 1.15 for AbstractOperatorRestoreTestBase and create snapshots

[gaoyunhaii]

This is an automated email from the ASF dual-hosted git repository.

gaoyunhaii pushed a commit to branch 1.15_create
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 68cc19f78cb234437cd8638f8738452dede3edc7
Author: Yun Gao <gaoyunhen...@gmail.com>
AuthorDate: Sun May 8 00:31:14 2022 +0800

    [release] Upgrade current version to 1.15 for 
AbstractOperatorRestoreTestBase and create snapshots
---
 .../keyed/AbstractKeyedOperatorRestoreTestBase.java     |  15 +--------------
 .../AbstractNonKeyedOperatorRestoreTestBase.java        |  15 +--------------
 .../operatorstate/complexKeyed-flink1.15/_metadata      | Bin 0 -> 13772 bytes
 .../operatorstate/nonKeyed-flink1.15/_metadata          | Bin 0 -> 3693 bytes
 4 files changed, 2 insertions(+), 28 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 d9c8733adaf..511829c41ce 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
@@ -28,7 +28,6 @@ import 
org.apache.flink.test.state.operator.restore.ExecutionMode;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 
-import java.util.Arrays;
 import java.util.Collection;
 
 /** Base class for all keyed operator restore tests. */
@@ -39,19 +38,7 @@ public abstract class AbstractKeyedOperatorRestoreTestBase 
extends AbstractOpera
 
     @Parameterized.Parameters(name = "Migrate Savepoint: {0}")
     public static Collection<FlinkVersion> parameters() {
-        return Arrays.asList(
-                FlinkVersion.v1_3,
-                FlinkVersion.v1_4,
-                FlinkVersion.v1_5,
-                FlinkVersion.v1_6,
-                FlinkVersion.v1_7,
-                FlinkVersion.v1_8,
-                FlinkVersion.v1_9,
-                FlinkVersion.v1_10,
-                FlinkVersion.v1_11,
-                FlinkVersion.v1_12,
-                FlinkVersion.v1_13,
-                FlinkVersion.v1_14);
+        return FlinkVersion.rangeOf(FlinkVersion.v1_3, FlinkVersion.v1_15);
     }
 
     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 257b8a2a6c9..ba2da3a1ded 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
@@ -28,7 +28,6 @@ import 
org.apache.flink.test.state.operator.restore.ExecutionMode;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 
-import java.util.Arrays;
 import java.util.Collection;
 
 import static 
org.apache.flink.test.state.operator.restore.unkeyed.NonKeyedJob.createFirstStatefulMap;
@@ -46,19 +45,7 @@ public abstract class AbstractNonKeyedOperatorRestoreTestBase
 
     @Parameterized.Parameters(name = "Migrate Savepoint: {0}")
     public static Collection<FlinkVersion> parameters() {
-        return Arrays.asList(
-                FlinkVersion.v1_3,
-                FlinkVersion.v1_4,
-                FlinkVersion.v1_5,
-                FlinkVersion.v1_6,
-                FlinkVersion.v1_7,
-                FlinkVersion.v1_8,
-                FlinkVersion.v1_9,
-                FlinkVersion.v1_10,
-                FlinkVersion.v1_11,
-                FlinkVersion.v1_12,
-                FlinkVersion.v1_13,
-                FlinkVersion.v1_14);
+        return FlinkVersion.rangeOf(FlinkVersion.v1_3, FlinkVersion.v1_15);
     }
 
     protected AbstractNonKeyedOperatorRestoreTestBase(FlinkVersion 
flinkVersion) {
diff --git 
a/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.15/_metadata 
b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.15/_metadata
new file mode 100644
index 00000000000..216268e0c6d
Binary files /dev/null and 
b/flink-tests/src/test/resources/operatorstate/complexKeyed-flink1.15/_metadata 
differ
diff --git 
a/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.15/_metadata 
b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.15/_metadata
new file mode 100644
index 00000000000..17e95d39e0d
Binary files /dev/null and 
b/flink-tests/src/test/resources/operatorstate/nonKeyed-flink1.15/_metadata 
differ