set default size for the blocking queue to Integer.MAX_VALUE

MeihanLi · MeihanLi · commit 827c53717b1b · 2023-04-18T13:13:27.000-07:00
diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/broker/BrokerManagedAsyncExecutorProvider.java b/pinot-broker/src/main/java/org/apache/pinot/broker/broker/BrokerManagedAsyncExecutorProvider.java
@@ -20,6 +20,7 @@
 
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.RejectedExecutionHandler;
 import java.util.concurrent.ThreadPoolExecutor;
 import javax.ws.rs.ServiceUnavailableException;
@@ -68,6 +69,9 @@ protected int getCorePoolSize() {
 
   @Override
   protected BlockingQueue<Runnable> getWorkQueue() {
+    if (_queueSize == Integer.MAX_VALUE) {
+      return new LinkedBlockingQueue();
+    }
     return new ArrayBlockingQueue(_queueSize);
   }
 
diff --git a/pinot-spi/src/main/java/org/apache/pinot/spi/utils/CommonConstants.java b/pinot-spi/src/main/java/org/apache/pinot/spi/utils/CommonConstants.java
@@ -260,8 +260,7 @@ public static class Broker {
             Runtime.getRuntime().availableProcessors() * 2;
     public static final String CONFIG_OF_JERSEY_THREADPOOL_EXECUTOR_QUEUE_SIZE =
             "pinot.broker.jersey.threadpool.executor.queue.size";
-    public static final int DEFAULT_JERSEY_THREADPOOL_EXECUTOR_QUEUE_SIZE =
-        Runtime.getRuntime().availableProcessors() * 2;
+    public static final int DEFAULT_JERSEY_THREADPOOL_EXECUTOR_QUEUE_SIZE = Integer.MAX_VALUE;
 
     // used for SQL GROUP BY during broker reduce
     public static final String CONFIG_OF_BROKER_GROUPBY_TRIM_THRESHOLD = "pinot.broker.groupby.trim.threshold";
