[flink-connector-pulsar] 05/27: [FLINK-25159][tests] Disable broken E2E tests

[martijnvisser]

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.