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

tanxinyu 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 c82bcdb4ab2 Increase region migration pool size on DataNode (#12366)
c82bcdb4ab2 is described below

commit c82bcdb4ab2ae3e6bf151725027bba9ebdcfd5a9
Author: Li Yu Heng <[email protected]>
AuthorDate: Thu Apr 18 14:15:09 2024 +0800

    Increase region migration pool size on DataNode (#12366)
    
    * done
    
    * use fixedThreadPool
---
 .../main/java/org/apache/iotdb/db/service/RegionMigrateService.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java
index c021920f27a..11a47d7dc20 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/RegionMigrateService.java
@@ -217,7 +217,8 @@ public class RegionMigrateService implements IService {
 
     private RegionMigratePool() {
       this.pool =
-          
IoTDBThreadPoolFactory.newSingleThreadExecutor(ThreadName.REGION_MIGRATE.getName());
+          IoTDBThreadPoolFactory.newCachedThreadPool(
+              ThreadName.REGION_MIGRATE.getName(), 
Runtime.getRuntime().availableProcessors() / 2);
     }
 
     @Override

Reply via email to