[fix][client] Fix memory leak in ClientCnx.newLookup when there's Too…

…ManyRequestsException (#23971)
apache · Feb 12, 2025 · 6a61464 · 6a61464
1 parent 88fbeb2
commit 6a61464
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
@@ -925,6 +925,7 @@ public CompletableFuture<LookupDataResult> newLookup(ByteBuf request, long reque
             if (maxLookupRequestSemaphore.tryAcquire()) {
                 waitingLookupRequests.add(Pair.of(requestId, Pair.of(request, future)));
             } else {
+                request.release();
                 if (log.isDebugEnabled()) {
                     log.debug("{} Failed to add lookup-request into waiting queue", requestId);
                 }