[Fix](Branch-2.1) fix fallback to legacy planner when set group commi…

…t in session variable
eldenmoon · Oct 16, 2024 · 717885c · 717885c
1 parent e562162
commit 717885c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
@@ -238,7 +238,9 @@ public void executeQuery(MysqlCommand mysqlCommand, String originStmt) throws Ex
         long parseSqlStartTime = System.currentTimeMillis();
         List<StatementBase> cachedStmts = null;
         CacheKeyType cacheKeyType = null;
-        if (!sessionVariable.isEnableInsertGroupCommit() && sessionVariable.isEnableNereidsPlanner()) {
+        boolean isGroupCommitFromPreparedStatement =
+                sessionVariable.isEnableInsertGroupCommit() && mysqlCommand != MysqlCommand.COM_QUERY;
+        if (!isGroupCommitFromPreparedStatement && sessionVariable.isEnableNereidsPlanner()) {
             if (wantToParseSqlFromSqlCache) {
                 cachedStmts = parseFromSqlCache(originStmt);
                 Optional<SqlCacheContext> sqlCacheContext = ConnectContext.get()