You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/05/28 18:32:25 UTC

[pulsar] branch master updated: Use at least 8 threads in Jetty thread pool in pulsar proxy (#4375)

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

mmerli 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 e5873ef  Use at least 8 threads in Jetty thread pool in pulsar proxy (#4375)
e5873ef is described below

commit e5873ef26259c1d4e0e0b61ae4a6548b503f9718
Author: Sijie Guo <si...@apache.org>
AuthorDate: Wed May 29 02:32:16 2019 +0800

    Use at least 8 threads in Jetty thread pool in pulsar proxy (#4375)
    
    fixes #4359
    
    same as #3776
    
    Use at least 8 threads to avoid having Jetty go into threads starving and
    having the possibility of getting into a deadlock where a Jetty thread is
    waiting for another HTTP call to complete in same thread.
---
 .../main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java
index 389e1d2..442ea57 100644
--- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java
+++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java
@@ -338,7 +338,7 @@ public class ProxyConfiguration implements PulsarConfiguration {
            category = CATEGORY_HTTP,
            doc = "Number of threads to use for HTTP requests processing"
     )
-    private int httpNumThreads = Math.max(4, 2 * Runtime.getRuntime().availableProcessors());
+    private int httpNumThreads = Math.max(8, 2 * Runtime.getRuntime().availableProcessors());
 
     @PropertiesContext(
         properties = {