Skip to content
Permalink
Browse files
[release] Upgrade current version to 1.15 for FlinkKafkaProducerMigra…
…tionTest and create snapshots
  • Loading branch information
gaoyunhaii committed May 8, 2022
1 parent 9738c07 commit 5e7b0d41ca200d932c6d5f4fcf53e7bf194c339a
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 9 deletions.
@@ -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) {
Binary file not shown.

0 comments on commit 5e7b0d4

Please sign in to comment.