[FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests tempo…

…rarily
rxp90 · Feb 16, 2022 · 20e03f4 · 20e03f4
1 parent 9bd61e1
commit 20e03f4
Showing 1 changed file 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
@@ -24,17 +24,41 @@
 import org.apache.flink.connector.pulsar.testutils.cases.SingleTopicConsumingContext;
 import org.apache.flink.connector.pulsar.testutils.runtime.PulsarRuntime;
 import org.apache.flink.connector.testframe.environment.MiniClusterTestEnvironment;
+import org.apache.flink.connector.testframe.environment.TestEnvironment;
+import org.apache.flink.connector.testframe.external.source.DataStreamSourceExternalContext;
 import org.apache.flink.connector.testframe.junit.annotations.TestContext;
 import org.apache.flink.connector.testframe.junit.annotations.TestEnv;
 import org.apache.flink.connector.testframe.junit.annotations.TestExternalSystem;
 import org.apache.flink.connector.testframe.junit.annotations.TestSemantics;
 import org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase;
 import org.apache.flink.streaming.api.CheckpointingMode;
 
+import org.junit.jupiter.api.Disabled;
+
 /** Unite test class for {@link PulsarSource}. */
 @SuppressWarnings("unused")
 class PulsarSourceITCase extends SourceTestSuiteBase<String> {
 
+ @Disabled // TODO: remove override after FLINK-26177 is fixed
+ @Override
+ public void testScaleUp(
+ TestEnvironment testEnv,
+ DataStreamSourceExternalContext<String> externalContext,
+ CheckpointingMode semantic)
+ throws Exception {
+ super.testScaleUp(testEnv, externalContext, semantic);
+ }
+
+ @Disabled // TODO: remove override after FLINK-26177 is fixed
+ @Override
+ public void testScaleDown(
+ TestEnvironment testEnv,
+ DataStreamSourceExternalContext<String> externalContext,
+ CheckpointingMode semantic)
+ throws Exception {
+ super.testScaleDown(testEnv, externalContext, semantic);
+ }
+
  // Defines test environment on Flink MiniCluster
  @TestEnv MiniClusterTestEnvironment flink = new MiniClusterTestEnvironment();