[iotdb] branch master updated: Add default pool size for data block exchange pool (#6480)

[jackietien]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new b6ca325434 Add default pool size for data block exchange pool (#6480)
b6ca325434 is described below

commit b6ca325434cd85517f2403f51a49d67e4c25273e
Author: Jackie Tien <jackietie...@gmail.com>
AuthorDate: Tue Jun 28 15:42:30 2022 +0800

    Add default pool size for data block exchange pool (#6480)
---
 server/src/assembly/resources/conf/iotdb-datanode.properties   | 4 ++--
 server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/server/src/assembly/resources/conf/iotdb-datanode.properties 
b/server/src/assembly/resources/conf/iotdb-datanode.properties
index af925f2c95..c917204313 100644
--- a/server/src/assembly/resources/conf/iotdb-datanode.properties
+++ b/server/src/assembly/resources/conf/iotdb-datanode.properties
@@ -34,10 +34,10 @@ rpc_port=6667
 mpp_data_exchange_port=8777
 
 # Datatype: int
-# mpp_data_exchange_core_pool_size=1
+# mpp_data_exchange_core_pool_size=10
 
 # Datatype: int
-# mpp_data_exchange_max_pool_size=5
+# mpp_data_exchange_max_pool_size=10
 
 # Datatype: int
 # mpp_data_exchange_keep_alive_time_in_ms=1000
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 d27da1e114..0ceae86ee6 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
@@ -872,10 +872,10 @@ public class IoTDBConfig {
   private int mppDataExchangePort = 8777;
 
   /** Core pool size of mpp data exchange. */
-  private int mppDataExchangeCorePoolSize = 1;
+  private int mppDataExchangeCorePoolSize = 10;
 
   /** Max pool size of mpp data exchange. */
-  private int mppDataExchangeMaxPoolSize = 5;
+  private int mppDataExchangeMaxPoolSize = 10;
 
   /** Thread keep alive time in ms of mpp data exchange. */
   private int mppDataExchangeKeepAliveTimeInMs = 1000;