diff --git a/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java b/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java index 9fba1fd9f6..3a792e6ef2 100644 --- a/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java +++ b/src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLResponseService.java @@ -578,7 +578,7 @@ public BufferPoolRecord.Builder generateBufferRecordBuilder() { @Override protected Executor getExecutor() { Executor executor; - if (complexQuery) { + if (complexQuery || SystemConfig.getInstance().getUsePerformanceMode() == 1) { executor = DbleServer.getInstance().getComplexQueryExecutor(); } else { executor = DbleServer.getInstance().getBackendExecutor();