(pulsar) branch branch-2.11 updated: [fix][broker] Fix lookupRequestSemaphore leak when topic not found (#21646)

[technoboy]

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

technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.11 by this push:
     new 942f462d7b1 [fix][broker] Fix lookupRequestSemaphore leak when topic 
not found (#21646)
942f462d7b1 is described below

commit 942f462d7b1eb9c1c032ffaa0a70e0ee65a09ccf
Author: pengxiangrui127 <67997328+pengxiangrui...@users.noreply.github.com>
AuthorDate: Mon Dec 4 09:42:59 2023 +0800

    [fix][broker] Fix lookupRequestSemaphore leak when topic not found (#21646)
---
 .../main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
index d7000cf712a..8ff027d3ed3 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java
@@ -130,10 +130,10 @@ public class TopicLookupBase extends PulsarWebResource {
                             
pulsar().getBrokerService().getLookupRequestSemaphore().release();
                             return result.getLookupData();
                         }
-                    }).exceptionally(ex->{
-                        
pulsar().getBrokerService().getLookupRequestSemaphore().release();
-                        throw FutureUtil.wrapToCompletionException(ex);
                     });
+                }).exceptionally(ex -> {
+                    
pulsar().getBrokerService().getLookupRequestSemaphore().release();
+                    throw FutureUtil.wrapToCompletionException(ex);
                 });
     }