commit 1fd44908e76881cd8035f0772a9cdccc7bafb62d
author gaozhangmin <gaozhangmin456@qq.com> Fri Jan 14 11:44:56 2022 +0800
committer GitHub <noreply@github.com> Fri Jan 14 11:44:56 2022 +0800
tree c88db9580c39286215924246f5d9e2d7d89e0130
parent 528c972eff6d9c41adb40a6dad42e9432487d187

Fix Flaky test BacklogQuotaManagerTest.testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#13724)

pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
index c61f5d3..2fcc693 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java
@@ -503,6 +503,7 @@
         consumer.receive();
 
         admin.topics().unload(topic);
+        Awaitility.await().until(consumer::isConnected);
         PersistentTopicInternalStats internalStats = admin.topics().getInternalStats(topic);
         assertEquals(internalStats.ledgers.size(), 2);
         assertEquals(internalStats.ledgers.get(1).entries, 0);