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 2022/07/26 10:50:42 UTC
[flink] branch master updated: [FLINK-28267][test] Disable KafkaSourceLegacyITCase#testBrokerFailure
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 a8780810861 [FLINK-28267][test] Disable KafkaSourceLegacyITCase#testBrokerFailure
a8780810861 is described below
commit a87808108614ef7b1d40d0e994c2683b272e41d5
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Jul 26 12:50:24 2022 +0200
[FLINK-28267][test] Disable KafkaSourceLegacyITCase#testBrokerFailure
---
.../apache/flink/connector/kafka/source/KafkaSourceLegacyITCase.java | 2 ++
1 file changed, 2 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 9390eb566d8..5cc0ddf63ed 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;
/**
@@ -90,6 +91,7 @@ public class KafkaSourceLegacyITCase extends KafkaConsumerTestBase {
// --- broker failure ---
@Test
+ @Ignore("FLINK-28267")
public void testBrokerFailure() throws Exception {
runBrokerFailureTest();
}