[inner-2371] fix: sql execution hang problem caused by the inability …

…to respond to the front side due to unprocessed packets. (cherry picked from commit dcff228、07c0c1f1c986a71fb74d0fcc0379965592c63b49)
actiontech · Jan 1, 2024 · 363fde3 · 363fde3
1 parent 5eb3652
commit 363fde3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/main/java/com/actiontech/dble/services/BackendService.java b/src/main/java/com/actiontech/dble/services/BackendService.java
@@ -102,8 +102,8 @@ protected void doHandle(ServiceTask task) {
                     handleDataError(e);
                 } finally {
                     isHandling.set(false);
-                    if (taskQueue.size() > 0) {
-                        doHandle(null);
+                    if (!taskQueue.isEmpty()) {
+                        doHandle(taskQueue.peek());
                     }
                 }
             });
@@ -125,7 +125,7 @@ public void execute(ServiceTask task) {
             handleDataError(e);
         } finally {
             isHandling.set(false);
-            if (taskQueue.size() > 0) {
+            if (!taskQueue.isEmpty()) {
                 doHandle(task);
             }
         }
@@ -215,7 +215,7 @@ protected void handleInnerData(byte[] data) {
     protected void handleDataError(Exception e) {
         LOGGER.warn(this.toString() + " handle data error:", e);
         connection.close("handle data error:" + e.getMessage());
-        while (taskQueue.size() > 0) {
+        while (!taskQueue.isEmpty()) {
             clearTaskQueue();
             // clear all data from the client
             LockSupport.parkNanos(TimeUnit.MILLISECONDS.toNanos(1000));

diff --git a/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java b/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java
@@ -491,7 +491,7 @@ protected boolean beforeHandlingTask() {
     @Override
     protected Executor getExecutor() {
         Executor executor;
-        if (complexQuery) {
+        if (complexQuery || SystemConfig.getInstance().getUsePerformanceMode() == 1) {
             executor = DbleServer.getInstance().getComplexQueryExecutor();
         } else {
             executor = DbleServer.getInstance().getBackendBusinessExecutor();