You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/07/25 04:21:00 UTC
[pulsar] 12/12: Fix newLookup TooManyRequestsException message (#16594)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 98d1cc94d7a5acee12007792197b1b893b63cb71
Author: Xiaoyu Hou <An...@gmail.com>
AuthorDate: Mon Jul 25 10:42:35 2022 +0800
Fix newLookup TooManyRequestsException message (#16594)
(cherry picked from commit 595bb55b8537ccb0da12dc7741a0e21fb30c23aa)
---
.../src/main/java/org/apache/pulsar/client/impl/ClientCnx.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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
index 322138699d5..033365b362b 100644
--- 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
@@ -774,7 +774,7 @@ public class ClientCnx extends PulsarHandler {
future.completeExceptionally(new PulsarClientException.TooManyRequestsException(String.format(
"Requests number out of config: There are {%s} lookup requests outstanding and {%s} requests"
+ " pending.",
- pendingLookupRequestSemaphore.availablePermits(),
+ pendingLookupRequestSemaphore.getQueueLength(),
waitingLookupRequests.size())));
}
}