You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/12/12 12:17:29 UTC
[flink] branch master updated: [FLINK-25266][tests] Disable StreamingKafkaITCase
This is an automated email from the ASF dual-hosted git repository.
chesnay 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 6b88201 [FLINK-25266][tests] Disable StreamingKafkaITCase
6b88201 is described below
commit 6b88201913e365a763d2150e3bc7c41716f8a252
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Sun Dec 12 13:17:01 2021 +0100
[FLINK-25266][tests] Disable StreamingKafkaITCase
---
.../java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java | 2 ++
1 file changed, 2 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/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..23ef8c2 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-25266")
public class StreamingKafkaITCase extends TestLogger {
private static final Logger LOG = LoggerFactory.getLogger(StreamingKafkaITCase.class);