From 70d83e29cc5fc0b7017e28e5146e88e3b322faad Mon Sep 17 00:00:00 2001
From: Jeff Xiang <jxiang@pinterest.com>
Date: Fri, 13 Dec 2024 15:18:15 -0500
Subject: [PATCH] Add thread.sleep(5s) in
 FlinkPscProducerITCase.testFlinkPscProducerFailBeforeNotify to allow for
 broker startup before deleting topic

---
 .../flink/streaming/connectors/psc/FlinkPscProducerITCase.java  | 1 +
 psc/src/test/resources/log4j2-test.xml                          | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java b/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java
index 17defec..eb82a57 100644
--- a/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java
+++ b/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java
@@ -205,6 +205,7 @@ public void testFlinkPscProducerFailBeforeNotify() throws Exception {
 
         assertExactlyOnceForTopicUri(createProperties(), topicUri, 0, Arrays.asList(42, 43));
 
+        Thread.sleep(5000); // wait for broker to start up before deleting topic
         deleteTestTopic(topic);
         checkProducerLeak();
     }
diff --git a/psc/src/test/resources/log4j2-test.xml b/psc/src/test/resources/log4j2-test.xml
index 116575d..9e25415 100644
--- a/psc/src/test/resources/log4j2-test.xml
+++ b/psc/src/test/resources/log4j2-test.xml
@@ -12,7 +12,7 @@
     </Appenders>
 
     <Loggers>
-        <AsyncRoot level="info" includeLocation="true">
+        <AsyncRoot level="error" includeLocation="true">
             <AppenderRef ref="console"/>
         </AsyncRoot>
     </Loggers>