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 <[email protected]> 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 {
