From a276e00b40423298e29d471ac8afdc76f1052638 Mon Sep 17 00:00:00 2001
From: wenyh <44251917+wenyh1@users.noreply.github.com>
Date: Mon, 11 Sep 2023 17:57:58 +0800
Subject: [PATCH] [inner-2350] need to deal with npe in performance mode

(cherry picked from commit 8fec8289488d7e96836ca22ce42c00b885644c9c)
---
 .../dble/services/mysqlauthenticate/MySQLBackAuthService.java    | 1 +
 .../dble/services/mysqlsharding/MySQLCurrentResponseService.java | 1 +
 2 files changed, 2 insertions(+)

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);
             }