[flink] 02/13: [release] Upgrade current version to 1.15 for FlinkKafkaConsumerBaseMigrationTest 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 c6a0d15891f533787a6423ceab73862a4acfbab5
Author: Yun Gao <gaoyunhen...@gmail.com>
AuthorDate: Sat May 7 12:11:13 2022 +0800

    [release] Upgrade current version to 1.15 for 
FlinkKafkaConsumerBaseMigrationTest and create snapshots
---
 .../kafka/FlinkKafkaConsumerBaseMigrationTest.java       |  14 +-------------
 ...onsumer-migration-test-flink1.15-empty-state-snapshot | Bin 0 -> 1465 bytes
 .../kafka-consumer-migration-test-flink1.15-snapshot     | Bin 0 -> 1519 bytes
 3 files changed, 1 insertion(+), 13 deletions(-)

diff --git 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
index 0ba99452922..645278c9597 100644
--- 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
+++ 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBaseMigrationTest.java
@@ -46,7 +46,6 @@ import org.mockito.invocation.InvocationOnMock;
 import org.mockito.stubbing.Answer;
 
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.HashMap;
@@ -94,18 +93,7 @@ public class FlinkKafkaConsumerBaseMigrationTest {
 
     @Parameterized.Parameters(name = "Migration Savepoint: {0}")
     public static Collection<FlinkVersion> parameters() {
-        return Arrays.asList(
-                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_4, FlinkVersion.v1_15);
     }
 
     public FlinkKafkaConsumerBaseMigrationTest(FlinkVersion 
testMigrateVersion) {
diff --git 
a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-empty-state-snapshot
 
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-empty-state-snapshot
new file mode 100644
index 00000000000..f6d3a17968c
Binary files /dev/null and 
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-empty-state-snapshot
 differ
diff --git 
a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-snapshot
 
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-snapshot
new file mode 100644
index 00000000000..7039d10413c
Binary files /dev/null and 
b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-consumer-migration-test-flink1.15-snapshot
 differ