This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 13d7e55 [FLINK-21796][FLINK-17510] Disable tests that use KafkaResource 13d7e55 is described below commit 13d7e557322ccd2dc6f4c7698e6c5fc23ca445a8 Author: Dawid Wysakowicz <dwysakow...@apache.org> AuthorDate: Tue Apr 20 17:00:38 2021 +0200 [FLINK-21796][FLINK-17510] Disable tests that use KafkaResource --- .../java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java | 2 ++ .../java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java index 560ad90..756b1c4 100644 --- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java +++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java @@ -35,6 +35,7 @@ import org.apache.commons.lang3.StringUtils; 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 @@ import static org.junit.Assert.assertThat; /** 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/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java index 278ffdb..3b0556f 100644 --- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java +++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java @@ -31,6 +31,7 @@ import org.apache.flink.testutils.junit.FailsOnJava11; 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 @@ import java.util.stream.Collectors; /** 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);