diff --git a/src/main/java/com/actiontech/dble/DbleServer.java b/src/main/java/com/actiontech/dble/DbleServer.java
index 3b4660f2e..bf02a4b60 100644
--- a/src/main/java/com/actiontech/dble/DbleServer.java
+++ b/src/main/java/com/actiontech/dble/DbleServer.java
@@ -300,7 +300,7 @@ public final class DbleServer {
         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 ee02db3d9..f3c319997 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 final class DbleThreadPool extends ManagerWritableTable {
             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 {