From fe9e13fca112501ff48ea4efb23979d425f1569b Mon Sep 17 00:00:00 2001 From: Qingsheng Ren Date: Tue, 15 Feb 2022 15:59:35 +0800 Subject: [PATCH] [FLINK-26143][connector/kafka] Temporarily disable FlinkKafkaProducerITCase.testFlinkKafkaProducerFailBeforeNotify because it hangs in IDE and CI --- .../streaming/connectors/kafka/FlinkKafkaProducerITCase.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java index a6b8760373c5d..4fdd44e2beaed 100644 --- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java +++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerITCase.java @@ -31,6 +31,7 @@ import org.apache.kafka.common.errors.ProducerFencedException; import org.junit.Before; +import org.junit.Ignore; import org.junit.Test; import java.util.ArrayList; @@ -173,6 +174,7 @@ public void testRestoreToCheckpointAfterExceedingProducersPool() throws Exceptio /** This test hangs when running it in your IDE. */ @Test + @Ignore public void testFlinkKafkaProducerFailBeforeNotify() throws Exception { String topic = "flink-kafka-producer-fail-before-notify";