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

technoboy 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 6101517d488 [fix][test]Fix resource not close after method (#20715)
6101517d488 is described below

commit 6101517d488a734c7a75b4e2e844230856adf41c
Author: feynmanlin <[email protected]>
AuthorDate: Wed Jul 5 08:41:23 2023 +0800

    [fix][test]Fix resource not close after method (#20715)
---
 .../org/apache/pulsar/broker/service/PublishRateLimiterTest.java | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
index b934ced08c5..f3cb25e789f 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PublishRateLimiterTest.java
@@ -21,6 +21,7 @@ package org.apache.pulsar.broker.service;
 import org.apache.pulsar.common.policies.data.Policies;
 import org.apache.pulsar.common.policies.data.PublishRate;
 import org.apache.pulsar.common.util.RateLimiter;
+import org.testng.annotations.AfterMethod;
 import org.testng.annotations.BeforeMethod;
 import org.testng.annotations.Test;
 
@@ -51,6 +52,14 @@ public class PublishRateLimiterTest {
         publishRateLimiter = new PublishRateLimiterImpl(policies, 
CLUSTER_NAME);
     }
 
+    @AfterMethod
+    public void cleanup() throws Exception {
+        policies.publishMaxMessageRate.clear();
+        policies.publishMaxMessageRate = null;
+        precisePublishLimiter.close();
+        publishRateLimiter.close();
+    }
+
     @Test
     public void testPublishRateLimiterImplExceed() throws Exception {
         // increment not exceed

Reply via email to