You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/01/18 07:56:16 UTC
[pulsar] 11/21: Fix Flaky test BacklogQuotaManagerTest.testConsumerBacklogEvictionTimeQuotaWithEmptyLedger (#13724)
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 <ga...@qq.com>
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);