You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fp...@apache.org on 2022/03/02 13:22:16 UTC
[flink] branch master updated: [FLINK-26387][connectors/kafka] Disable testBrokerFailure in ITCase tests
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ß <11...@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();