[fix][broker] Fix lookupRequestSemaphore leak when topic not found (#…

…21646)
apache · Dec 4, 2023 · 9fd3dc9 · 9fd3dc9
1 parent c8e9640
commit 9fd3dc9
Showing 1 changed file with 3 additions and 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
@@ -132,10 +132,10 @@ protected CompletableFuture<LookupData> internalLookupTopicAsync(final TopicName
                             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);
                 });
     }