This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 9ab1afffbdfe397cc75f3dfc1482eeb754f453c7 Author: gaozhangmin <[email protected]> AuthorDate: Fri Jan 14 11:44:56 2022 +0800 Fix Flaky test BacklogQuotaManagerTest.testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#13724) (cherry picked from commit 1fd44908e76881cd8035f0772a9cdccc7bafb62d) --- .../java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java | 1 + 1 file changed, 1 insertion(+) 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 c0fc189..a0c8fd9 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 @@ -497,6 +497,7 @@ public class BacklogQuotaManagerTest { 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);
