Add thread.sleep(5s) in FlinkPscProducerITCase.testFlinkPscProducerFa…

…ilBeforeNotify to allow for broker startup before deleting topic
pinterest · Dec 13, 2024 · 70d83e2 · 70d83e2
1 parent c7aa188
commit 70d83e2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/...nk/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java b/...nk/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
@@ -12,7 +12,7 @@
     </Appenders>
 
     <Loggers>
-        <AsyncRoot level="info" includeLocation="true">
+        <AsyncRoot level="error" includeLocation="true">
             <AppenderRef ref="console"/>
         </AsyncRoot>
     </Loggers>