[pulsar] branch master updated: [improve][broker] Add timeout for unload namespace bundle. #15719

[technoboy]

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 74b108d467a [improve][broker] Add timeout for unload namespace bundle. 
#15719
74b108d467a is described below

commit 74b108d467a5e198aae47d22304574890c513ffe
Author: Jiwei Guo <techno...@apache.org>
AuthorDate: Tue May 24 20:13:59 2022 -0700

    [improve][broker] Add timeout for unload namespace bundle. #15719
---
 .../main/java/org/apache/pulsar/broker/service/BrokerService.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index daea3e43828..532e41cfbd3 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -915,9 +915,9 @@ public class BrokerService implements Closeable {
                                 if (rateLimiter != null) {
                                     rateLimiter.acquire(1);
                                 }
-                                
pulsar.getNamespaceService().unloadNamespaceBundle(su, pulsar.getConfiguration()
-                                                
.getNamespaceBundleUnloadingTimeoutMs(), TimeUnit.MILLISECONDS,
-                                        
closeWithoutWaitingClientDisconnect).get();
+                                long timeout = 
pulsar.getConfiguration().getNamespaceBundleUnloadingTimeoutMs();
+                                
pulsar.getNamespaceService().unloadNamespaceBundle(su, timeout, 
TimeUnit.MILLISECONDS,
+                                        
closeWithoutWaitingClientDisconnect).get(timeout, TimeUnit.MILLISECONDS);
                             } catch (Exception e) {
                                 log.warn("Failed to unload namespace bundle 
{}", su, e);
                             }