You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rg...@apache.org on 2022/03/01 16:24:14 UTC
[pulsar] 05/21: [Flaky-Test] BacklogQuotaManagerTest#testProducerExceptionAndThenUnblockSizeQuota (#14213)
This is an automated email from the ASF dual-hosted git repository.
rgao pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 0e438a982ef74328495f0cf6102546f545fa4b58
Author: gaozhangmin <ga...@qq.com>
AuthorDate: Wed Feb 16 22:58:42 2022 +0800
[Flaky-Test] BacklogQuotaManagerTest#testProducerExceptionAndThenUnblockSizeQuota (#14213)
(cherry picked from commit cd172e7455f90955ac951d713a28c4a580fdf75d)
---
.../java/org/apache/pulsar/broker/service/BacklogQuotaManagerTest.java | 2 ++
1 file changed, 2 insertions(+)
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 f531119..21fcffa 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
@@ -1123,6 +1123,8 @@ public class BacklogQuotaManagerTest {
}
Thread.sleep((TIME_TO_CHECK_BACKLOG_QUOTA + 1) * 1000);
// publish should work now
+ producer.close();
+ producer = createProducer(client, topic1);
Exception sendException = null;
gotException = false;
try {