This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch v3.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
commit 269b19f182bd5737c11650a01b0d6695a175154a Author: Chesnay Schepler <ches...@apache.org> AuthorDate: Mon Dec 6 14:59:53 2021 +0100 [FLINK-25159][tests] Disable broken E2E tests --- .../org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java | 3 +++ .../apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java | 3 +++ 2 files changed, 6 insertions(+) diff --git a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java index 9a499e6..95c1486 100644 --- a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java +++ b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceOrderedE2ECase.java @@ -28,12 +28,15 @@ import org.apache.flink.tests.util.pulsar.cases.ExclusiveSubscriptionContext; import org.apache.flink.tests.util.pulsar.cases.FailoverSubscriptionContext; import org.apache.flink.tests.util.pulsar.common.FlinkContainerWithPulsarEnvironment; +import org.junit.jupiter.api.Disabled; + import static org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime.container; /** * Pulsar E2E test based on connector testing framework. It's used for Failover & Exclusive * subscription. */ +@Disabled("FLINK-25210") public class PulsarSourceOrderedE2ECase extends SourceTestSuiteBase<String> { // Defines TestEnvironment. diff --git a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java index 797c7b1..c59831f 100644 --- a/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java +++ b/flink-connector-pulsar-e2e-tests/src/test/java/org/apache/flink/tests/util/pulsar/PulsarSourceUnorderedE2ECase.java @@ -28,12 +28,15 @@ import org.apache.flink.tests.util.pulsar.cases.SharedSubscriptionContext; import org.apache.flink.tests.util.pulsar.common.FlinkContainerWithPulsarEnvironment; import org.apache.flink.tests.util.pulsar.common.UnorderedSourceTestSuiteBase; +import org.junit.jupiter.api.Disabled; + import static org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime.container; /** * Pulsar E2E test based on connector testing framework. It's used for Shared & Key_Shared * subscription. */ +@Disabled("FLINK-25210") public class PulsarSourceUnorderedE2ECase extends UnorderedSourceTestSuiteBase<String> { // Defines TestEnvironment.