[flink] branch master updated: [FLINK-26387][connectors/kafka] Disable testBrokerFailure in ITCase tests

[fpaul]

This is an automated email from the ASF dual-hosted git repository.

fpaul 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 ab20e80  [FLINK-26387][connectors/kafka] Disable testBrokerFailure in 
ITCase tests
ab20e80 is described below

commit ab20e80def1baba4d5ea89fb5cf22d43d1a52260
Author: Alexander Preuß <11444089+alp...@users.noreply.github.com>
AuthorDate: Wed Mar 2 13:10:23 2022 +0100

    [FLINK-26387][connectors/kafka] Disable testBrokerFailure in ITCase tests
---
 .../apache/flink/connector/kafka/source/KafkaSourceLegacyITCase.java    | 2 ++
 .../java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java   | 2 ++
 2 files changed, 4 insertions(+)

diff --git 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceLegacyITCase.java
 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceLegacyITCase.java
index 9390eb5..24cbb02 100644
--- 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceLegacyITCase.java
+++ 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceLegacyITCase.java
@@ -24,6 +24,7 @@ import 
org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase;
 import org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl;
 
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 /**
@@ -89,6 +90,7 @@ public class KafkaSourceLegacyITCase extends 
KafkaConsumerTestBase {
 
     // --- broker failure ---
 
+    @Ignore("FLINK-26387")
     @Test
     public void testBrokerFailure() throws Exception {
         runBrokerFailureTest();
diff --git 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java
 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java
index 4bbec36..d7b9372 100644
--- 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java
+++ 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java
@@ -39,6 +39,7 @@ import 
org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.junit.BeforeClass;
+import org.junit.Ignore;
 import org.junit.Test;
 
 import javax.annotation.Nullable;
@@ -107,6 +108,7 @@ public class KafkaITCase extends KafkaConsumerTestBase {
 
     // --- broker failure ---
 
+    @Ignore("FLINK-26393")
     @Test(timeout = 60000)
     public void testBrokerFailure() throws Exception {
         runBrokerFailureTest();