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 2020/05/12 06:45:38 UTC
[pulsar] branch master updated: Fix pulsar client admin thread
number explode (#6940)
This is an automated email from the ASF dual-hosted git repository.
penghui 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 90dba13 Fix pulsar client admin thread number explode (#6940)
90dba13 is described below
commit 90dba138c79b5e8a9d5c576ec75c31e24f778914
Author: hangc0276 <ha...@163.com>
AuthorDate: Tue May 12 14:45:26 2020 +0800
Fix pulsar client admin thread number explode (#6940)
---
.../pulsar/client/admin/internal/http/AsyncHttpConnector.java | 1 +
.../client/admin/internal/http/AsyncHttpConnectorProvider.java | 6 +++++-
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java
index 27bc25c..0d3f132 100644
--- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java
+++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java
@@ -101,6 +101,7 @@ public class AsyncHttpConnector implements Connector {
confBuilder.setReadTimeout(readTimeoutMs);
confBuilder.setUserAgent(String.format("Pulsar-Java-v%s", PulsarVersion.getVersion()));
confBuilder.setRequestTimeout(requestTimeoutMs);
+ confBuilder.setIoThreadsCount(conf.getNumIoThreads());
confBuilder.setKeepAliveStrategy(new DefaultKeepAliveStrategy() {
@Override
public boolean keepAlive(Request ahcRequest, HttpRequest request, HttpResponse response) {
diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnectorProvider.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnectorProvider.java
index 7250b5c..6c8e003 100644
--- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnectorProvider.java
+++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnectorProvider.java
@@ -31,6 +31,7 @@ import org.glassfish.jersey.client.spi.ConnectorProvider;
public class AsyncHttpConnectorProvider implements ConnectorProvider {
private final ClientConfigurationData conf;
+ private Connector connector;
public AsyncHttpConnectorProvider(ClientConfigurationData conf) {
this.conf = conf;
@@ -38,7 +39,10 @@ public class AsyncHttpConnectorProvider implements ConnectorProvider {
@Override
public Connector getConnector(Client client, Configuration runtimeConfig) {
- return new AsyncHttpConnector(client, conf);
+ if (connector == null) {
+ connector = new AsyncHttpConnector(client, conf);
+ }
+ return connector;
}