diff --git a/src/main/java/com/actiontech/dble/services/mysqlauthenticate/MySQLBackAuthService.java b/src/main/java/com/actiontech/dble/services/mysqlauthenticate/MySQLBackAuthService.java
index 87b228322..31d4e7840 100644
--- a/src/main/java/com/actiontech/dble/services/mysqlauthenticate/MySQLBackAuthService.java
+++ b/src/main/java/com/actiontech/dble/services/mysqlauthenticate/MySQLBackAuthService.java
@@ -222,6 +222,7 @@ public class MySQLBackAuthService extends BackendService implements AuthService
         if (SystemConfig.getInstance().getUsePerformanceMode() != 1) {
             super.doHandle(null);
         } else {
+            if (task == null) return;
             if (isHandling.compareAndSet(false, true)) {
                 DbleServer.getInstance().getConcurrentBackHandlerQueue().offer(task);
             }
diff --git a/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLCurrentResponseService.java b/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLCurrentResponseService.java
index bf843363a..82d628cde 100644
--- a/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLCurrentResponseService.java
+++ b/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLCurrentResponseService.java
@@ -18,6 +18,7 @@ public class MySQLCurrentResponseService extends MySQLResponseService {
         if (isComplexQuery()) {
             super.doHandle(null);
         } else {
+            if (task == null) return;
             if (isHandling.compareAndSet(false, true)) {
                 DbleServer.getInstance().getConcurrentBackHandlerQueue().offer(task);
             }