From 2d86dacbfd98bc7ec59f5bc1db425ffbae9fef92 Mon Sep 17 00:00:00 2001
From: guoaomen <www.guoao@foxmail.com>
Date: Fri, 6 Jan 2023 13:21:16 +0800
Subject: [PATCH] fix: runnableMap does not store complexQueryWorker threads

---
 .../java/com/actiontech/dble/DbleServer.java     |  2 +-
 .../information/tables/DbleThreadPool.java       | 16 ++++++++--------
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/actiontech/dble/DbleServer.java b/src/main/java/com/actiontech/dble/DbleServer.java
index 3b4660f2e2..bf02a4b60b 100644
--- a/src/main/java/com/actiontech/dble/DbleServer.java
+++ b/src/main/java/com/actiontech/dble/DbleServer.java
@@ -300,7 +300,7 @@ private void initExecutor(int frontProcessorCount, int backendProcessorCount) {
         businessExecutor = ExecutorUtil.createFixed(BUSINESS_EXECUTOR_NAME, SystemConfig.getInstance().getProcessorExecutor(), runnableMap);
         backendBusinessExecutor = ExecutorUtil.createFixed(BACKEND_BUSINESS_EXECUTOR_NAME, SystemConfig.getInstance().getBackendProcessorExecutor(), runnableMap);
         writeToBackendExecutor = ExecutorUtil.createFixed(WRITE_TO_BACKEND_EXECUTOR_NAME, SystemConfig.getInstance().getWriteToBackendExecutor(), runnableMap);
-        complexQueryExecutor = ExecutorUtil.createCached(COMPLEX_QUERY_EXECUTOR_NAME, SystemConfig.getInstance().getComplexExecutor(), runnableMap);
+        complexQueryExecutor = ExecutorUtil.createCached(COMPLEX_QUERY_EXECUTOR_NAME, SystemConfig.getInstance().getComplexExecutor(), null);
         timerExecutor = ExecutorUtil.createFixed(TIMER_EXECUTOR_NAME, 1);
         frontExecutor = ExecutorUtil.createFixed(FRONT_EXECUTOR_NAME, FRONT_BACKEND_SUFFIX, frontProcessorCount, runnableMap);
         backendExecutor = ExecutorUtil.createFixed(BACKEND_EXECUTOR_NAME, FRONT_BACKEND_SUFFIX, backendProcessorCount, runnableMap);
diff --git a/src/main/java/com/actiontech/dble/services/manager/information/tables/DbleThreadPool.java b/src/main/java/com/actiontech/dble/services/manager/information/tables/DbleThreadPool.java
index ee02db3d90..f3c3199976 100644
--- a/src/main/java/com/actiontech/dble/services/manager/information/tables/DbleThreadPool.java
+++ b/src/main/java/com/actiontech/dble/services/manager/information/tables/DbleThreadPool.java
@@ -123,15 +123,15 @@ public int updateRows(Set<LinkedHashMap<String, String>> affectPks, LinkedHashMa
             nameableExecutor.setCorePoolSize(corePoolSize);
             if (!nameableExecutor.getName().equals(DbleServer.COMPLEX_QUERY_EXECUTOR_NAME)) {
                 nameableExecutor.setMaximumPoolSize(corePoolSize);
-            }
-            if (oldSize < corePoolSize) {
-                try {
-                    increasePoolSize(nameableExecutor, corePoolSize - oldSize);
-                } catch (IOException e) {
-                    throw new SQLException(e.getMessage(), "42S22", ErrorCode.ER_YES);
+                if (oldSize < corePoolSize) {
+                    try {
+                        increasePoolSize(nameableExecutor, corePoolSize - oldSize);
+                    } catch (IOException e) {
+                        throw new SQLException(e.getMessage(), "42S22", ErrorCode.ER_YES);
+                    }
+                } else if (oldSize > corePoolSize) {
+                    decreasePoolSize(nameableExecutor, oldSize - corePoolSize);
                 }
-            } else if (oldSize > corePoolSize) {
-                decreasePoolSize(nameableExecutor, oldSize - corePoolSize);
             }
             //persistence
             try {