[pulsar] branch master updated: Fix Flaky test BacklogQuotaManagerTest.testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#13724)

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 1fd4490  Fix Flaky test 
BacklogQuotaManagerTest.testConsumerBacklogEvictionTimeQuotaWithEmptyLedger 
(#13724)
1fd4490 is described below

commit 1fd44908e76881cd8035f0772a9cdccc7bafb62d
Author: gaozhangmin <gaozhangmin...@qq.com>
AuthorDate: Fri Jan 14 11:44:56 2022 +0800

    Fix Flaky test 
BacklogQuotaManagerTest.testConsumerBacklogEvictionTimeQuotaWithEmptyLedger 
(#13724)
---
 .../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 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 @@ 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);