Minor fixes

pinterest · Oct 23, 2024 · e2190ef · e2190ef
1 parent b7f30bc
commit e2190ef
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...a/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationOperatorTest.java b/...a/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationOperatorTest.java
@@ -20,7 +20,6 @@
 
 import org.apache.flink.FlinkVersion;
 import org.junit.Ignore;
-import org.junit.jupiter.api.Disabled;
 import org.junit.runners.Parameterized;
 
 import java.util.Arrays;
@@ -34,7 +33,7 @@
  * by the {@link #getOperatorSnapshotPath(FlinkVersion)} method then copy the resource to the path
  * also specified by the {@link #getOperatorSnapshotPath(FlinkVersion)} method.
  */
-@Disabled("PSC does not support migration from FlinkKafkaProducer011")
+@Ignore("PSC does not support migration from FlinkKafkaProducer011")
 public class FlinkPscProducerMigrationOperatorTest extends FlinkPscProducerMigrationTest {
     @Parameterized.Parameters(name = "Migration Savepoint: {0}")
     public static Collection<FlinkVersion> parameters() {

diff --git a/...test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationTest.java b/...test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationTest.java
@@ -42,7 +42,7 @@
 public class FlinkPscProducerMigrationTest extends PscMigrationTestBase {
     @Parameterized.Parameters(name = "Migration Savepoint: {0}")
     public static Collection<FlinkVersion> parameters() {
-        return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_15);
+        return FlinkVersion.rangeOf(FlinkVersion.v1_11, FlinkVersion.v1_15);
     }
 
     public FlinkPscProducerMigrationTest(FlinkVersion testMigrateVersion) {