[iotdb] branch xingtanzjr/write_opt updated: change thread to 100

[xingtanzjr]

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

xingtanzjr pushed a commit to branch xingtanzjr/write_opt
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/xingtanzjr/write_opt by this 
push:
     new 3a4b080b9d change thread to 100
3a4b080b9d is described below

commit 3a4b080b9d2a723bd0820fc8025386d82cf5cf89
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Sun Jun 19 23:10:44 2022 +0800

    change thread to 100
---
 server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java   | 4 ++--
 .../src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java  | 9 +++++----
 2 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java 
b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index ee14868554..5de782e678 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -928,10 +928,10 @@ public class IoTDBConfig {
   private int triggerForwardMQTTPoolSize = 4;
 
   /** ThreadPool size for read operation in coordinator */
-  private int coordinatorReadExecutorSize = 30;
+  private int coordinatorReadExecutorSize = 100;
 
   /** ThreadPool size for write operation in coordinator */
-  private int coordinatorWriteExecutorSize = 30;
+  private int coordinatorWriteExecutorSize = 100;
 
   IoTDBConfig() {}
 
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
index b732313503..528234f7fc 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
@@ -23,6 +23,7 @@ import org.apache.iotdb.commons.client.IClientManager;
 import org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient;
 import org.apache.iotdb.commons.concurrent.IoTDBThreadPoolFactory;
 import org.apache.iotdb.db.client.DataNodeClientPoolFactory;
+import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.mpp.common.MPPQueryContext;
 import org.apache.iotdb.db.mpp.common.QueryId;
 import org.apache.iotdb.db.mpp.common.SessionInfo;
@@ -54,9 +55,7 @@ public class Coordinator {
   private static final Logger LOGGER = 
LoggerFactory.getLogger(Coordinator.class);
 
   private static final String COORDINATOR_EXECUTOR_NAME = "MPPCoordinator";
-  private static final int COORDINATOR_EXECUTOR_SIZE = 50;
   private static final String COORDINATOR_WRITE_EXECUTOR_NAME = 
"MPPCoordinatorWrite";
-  private static final int COORDINATOR_WRITE_EXECUTOR_SIZE = 50;
   private static final String COORDINATOR_SCHEDULED_EXECUTOR_NAME = 
"MPPCoordinatorScheduled";
   private static final int COORDINATOR_SCHEDULED_EXECUTOR_SIZE = 1;
 
@@ -146,13 +145,15 @@ public class Coordinator {
 
   // TODO: (xingtanzjr) need to redo once we have a concrete policy for the 
threadPool management
   private ExecutorService getQueryExecutor() {
+    int coordinatorReadExecutorSize = 
IoTDBDescriptor.getInstance().getConfig().getCoordinatorReadExecutorSize();
     return IoTDBThreadPoolFactory.newFixedThreadPool(
-        COORDINATOR_EXECUTOR_SIZE, COORDINATOR_EXECUTOR_NAME);
+        coordinatorReadExecutorSize, COORDINATOR_EXECUTOR_NAME);
   }
 
   private ExecutorService getWriteExecutor() {
+    int coordinatorWriteExecutorSize = 
IoTDBDescriptor.getInstance().getConfig().getCoordinatorWriteExecutorSize();
     return IoTDBThreadPoolFactory.newFixedThreadPool(
-        COORDINATOR_WRITE_EXECUTOR_SIZE, COORDINATOR_WRITE_EXECUTOR_NAME);
+        coordinatorWriteExecutorSize, COORDINATOR_WRITE_EXECUTOR_NAME);
   }
 
   // TODO: (xingtanzjr) need to redo once we have a concrete policy for the 
threadPool management