From e2190ef2e764e36704e1f13e4f5ad16c2a7b690d Mon Sep 17 00:00:00 2001 From: Jeff Xiang Date: Tue, 22 Oct 2024 20:19:31 -0400 Subject: [PATCH] Minor fixes --- .../connectors/psc/FlinkPscProducerMigrationOperatorTest.java | 3 +-- .../connectors/psc/FlinkPscProducerMigrationTest.java | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationOperatorTest.java b/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationOperatorTest.java index 926b3c2..4e0b3cd 100644 --- a/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationOperatorTest.java +++ b/psc-flink/src/test/java/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 parameters() { diff --git a/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationTest.java b/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationTest.java index 4690bf9..c3cb410 100644 --- a/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerMigrationTest.java +++ b/psc-flink/src/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 parameters() { - return FlinkVersion.rangeOf(FlinkVersion.v1_8, FlinkVersion.v1_15); + return FlinkVersion.rangeOf(FlinkVersion.v1_11, FlinkVersion.v1_15); } public FlinkPscProducerMigrationTest(FlinkVersion testMigrateVersion) {