Skip to content

Commit

Permalink
[FLINK-26143][connector/kafka] Temporarily disable FlinkKafkaProducer…
Browse files Browse the repository at this point in the history
…ITCase.testFlinkKafkaProducerFailBeforeNotify because it hangs in IDE and CI
  • Loading branch information
PatrickRen authored and fapaul committed Feb 25, 2022
1 parent d4258b7 commit fe9e13f
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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";

Expand Down

0 comments on commit fe9e13f

Please sign in to comment.