This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit f3bf499b83a263f5bfc3da77def18c9c55b0d972 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 f706b3f..f531119 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 @@ -504,6 +504,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);
