[hotfix][tests] Disabling flaky source testing + PulsarSourceITCase c…

…ases. (cherry picked from commit 37c2e23)
apache · Aug 28, 2021 · 2d9c9be · 2d9c9be
1 parent 3c52ad7
commit 2d9c9be
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/...tor-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java b/...tor-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java
@@ -23,12 +23,17 @@
 import org.apache.flink.connector.pulsar.testutils.cases.MultipleTopicConsumingContext;
 import org.apache.flink.connector.pulsar.testutils.cases.SingleTopicConsumingContext;
 import org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime;
+import org.apache.flink.connectors.test.common.environment.ClusterControllable;
 import org.apache.flink.connectors.test.common.environment.MiniClusterTestEnvironment;
+import org.apache.flink.connectors.test.common.environment.TestEnvironment;
+import org.apache.flink.connectors.test.common.external.ExternalContext;
 import org.apache.flink.connectors.test.common.junit.annotations.ExternalContextFactory;
 import org.apache.flink.connectors.test.common.junit.annotations.ExternalSystem;
 import org.apache.flink.connectors.test.common.junit.annotations.TestEnv;
 import org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase;
 
+import org.junit.jupiter.api.Disabled;
+
 /** Unite test class for {@link PulsarSource}. */
 @SuppressWarnings("unused")
 class PulsarSourceITCase extends SourceTestSuiteBase<String> {
@@ -48,4 +53,21 @@ class PulsarSourceITCase extends SourceTestSuiteBase<String> {
     @ExternalContextFactory
     PulsarTestContextFactory<String, MultipleTopicConsumingContext> multipleTopic =
             new PulsarTestContextFactory<>(pulsar, MultipleTopicConsumingContext::new);
+
+    @Disabled
+    @Override
+    public void testMultipleSplits(TestEnvironment testEnv, ExternalContext<String> externalContext)
+            throws Exception {
+        super.testMultipleSplits(testEnv, externalContext);
+    }
+
+    @Disabled
+    @Override
+    public void testTaskManagerFailure(
+            TestEnvironment testEnv,
+            ExternalContext<String> externalContext,
+            ClusterControllable controller)
+            throws Exception {
+        super.testTaskManagerFailure(testEnv, externalContext, controller);
+    }
 }
diff --git a/...src/main/java/org/apache/flink/connectors/test/common/testsuites/SourceTestSuiteBase.java b/...src/main/java/org/apache/flink/connectors/test/common/testsuites/SourceTestSuiteBase.java
@@ -41,6 +41,7 @@
 import org.apache.flink.streaming.api.operators.collect.CollectStreamSink;
 import org.apache.flink.util.CloseableIterator;
 
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.TestInstance;
 import org.junit.jupiter.api.TestTemplate;
@@ -173,6 +174,7 @@ public void testMultipleSplits(TestEnvironment testEnv, ExternalContext<T> exter
      */
     @TestTemplate
     @DisplayName("Test source with at least one idle parallelism")
+    @Disabled
     public void testIdleReader(TestEnvironment testEnv, ExternalContext<T> externalContext)
             throws Exception {