[incubator-dolphinscheduler] branch dev updated: [Improvement][LogServer] Thread pool parameter adjustment #5161 (#5163)

[kirs]

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

kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 97fb08f  [Improvement][LogServer] Thread pool parameter adjustment 
#5161 (#5163)
97fb08f is described below

commit 97fb08f0ced20a4b9563725ed9e9600e5ea5722b
Author: wenjun <861923...@qq.com>
AuthorDate: Fri Apr 2 14:24:37 2021 +0800

    [Improvement][LogServer] Thread pool parameter adjustment #5161 (#5163)
    
    * [Improvement][LogServer] Thread pool parameter adjustment #5161
    
    * change log request processor thread num 2 * cpuCores + 1
---
 .../apache/dolphinscheduler/server/log/LoggerRequestProcessor.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/log/LoggerRequestProcessor.java
 
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/log/LoggerRequestProcessor.java
index c60a447..c9350bf 100644
--- 
a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/log/LoggerRequestProcessor.java
+++ 
b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/log/LoggerRequestProcessor.java
@@ -31,6 +31,7 @@ import 
org.apache.dolphinscheduler.remote.command.log.RollViewLogResponseCommand
 import org.apache.dolphinscheduler.remote.command.log.ViewLogRequestCommand;
 import org.apache.dolphinscheduler.remote.command.log.ViewLogResponseCommand;
 import org.apache.dolphinscheduler.remote.processor.NettyRequestProcessor;
+import org.apache.dolphinscheduler.remote.utils.Constants;
 
 import java.io.ByteArrayOutputStream;
 import java.io.File;
@@ -42,6 +43,7 @@ import java.nio.file.Paths;
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
@@ -60,10 +62,10 @@ public class LoggerRequestProcessor implements 
NettyRequestProcessor {
 
     private final Logger logger = 
LoggerFactory.getLogger(LoggerRequestProcessor.class);
 
-    private final ThreadPoolExecutor executor;
+    private final ExecutorService executor;
 
     public LoggerRequestProcessor() {
-        this.executor = new ThreadPoolExecutor(4, 4, 10, TimeUnit.SECONDS, new 
LinkedBlockingQueue<>(100));
+        this.executor = Executors.newFixedThreadPool(Constants.CPUS * 2 + 1);
     }
 
     @Override