[release] Upgrade current version to 1.15 for FlinkKafkaProducerMigra…

…tionTest and create snapshots
pppsunil · May 8, 2022 · 5e7b0d4 · 5e7b0d4
1 parent 9738c07
commit 5e7b0d4
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 9 deletions.
diff --git a/...est/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java b/...est/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java
@@ -28,7 +28,6 @@
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
 
-import java.util.Arrays;
 import java.util.Collection;
 import java.util.Properties;
 
@@ -43,14 +42,7 @@
 public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase {
     @Parameterized.Parameters(name = "Migration Savepoint: {0}")
     public static Collection<FlinkVersion> parameters() {
-        return Arrays.asList(
-                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_8, FlinkVersion.v1_15);
     }
 
     public FlinkKafkaProducerMigrationTest(FlinkVersion testMigrateVersion) {

diff --git a/...ink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.15-snapshot b/...ink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.15-snapshot