[FLINK-21796][FLINK-17510] Disable tests that use KafkaResource

bbejeck · Apr 20, 2021 · 13d7e55 · 13d7e55
1 parent cd3415f
commit 13d7e55
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java b/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
@@ -35,6 +35,7 @@
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.ClassRule;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
@@ -65,6 +66,7 @@
 /** End-to-end test for the kafka SQL connectors. */
 @RunWith(Parameterized.class)
 @Category(value = {TravisGroup1.class, FailsOnJava11.class})
+@Ignore("FLINK-21796")
 public class SQLClientKafkaITCase extends TestLogger {
 
  private static final Logger LOG = LoggerFactory.getLogger(SQLClientKafkaITCase.class);

diff --git a/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java b/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java
@@ -31,6 +31,7 @@
 import org.apache.flink.util.TestLogger;
 
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
@@ -52,6 +53,7 @@
 /** End-to-end test for the kafka connectors. */
 @RunWith(Parameterized.class)
 @Category(value = {TravisGroup1.class, PreCommit.class, FailsOnJava11.class})
+@Ignore("FLINK-17510")
 public class StreamingKafkaITCase extends TestLogger {
 
  private static final Logger LOG = LoggerFactory.getLogger(StreamingKafkaITCase.class);