This is an automated email from the ASF dual-hosted git repository.
eldenmoon pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new f98aa1d08bb [Fix](Branch-2.1) fix fallback to legacy planner when set
group commit in session variable (#41984)
f98aa1d08bb is described below
commit f98aa1d08bb6aae9aecc1063a9dd31921a2b43b0
Author: lihangyu <[email protected]>
AuthorDate: Thu Oct 17 10:40:33 2024 +0800
[Fix](Branch-2.1) fix fallback to legacy planner when set group commit in
session variable (#41984)
---
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java | 4 +++-
1 file changed, 3 insertions(+), 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
index d1538284b22..5531ce1e076 100644
--- 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 abstract class ConnectProcessor {
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()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
