This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new d468c68d487 [fix](group commit) Fix group commit connect to observer
fe (#32222)
d468c68d487 is described below
commit d468c68d487f8f51b6f26720fd0d379f3d234563
Author: meiyi <[email protected]>
AuthorDate: Tue Mar 19 19:52:20 2024 +0800
[fix](group commit) Fix group commit connect to observer fe (#32222)
---
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index 72073e1e847..c882ea3c418 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -663,6 +663,13 @@ public class StmtExecutor {
+ Env.getCurrentEnv().getSelfNode().getHost()
+ ") and failed to execute"
+ " because Master FE is not ready. You may
need to check FE's status"));
}
+ if
(context.getSessionVariable().isEnableInsertGroupCommit()) {
+ // FIXME: Group commit insert does not need to forward
to master
+ // Nereids does not support group commit, so we can
not judge if should forward
+ // Here throw an exception to fallback to legacy
planner and let legacy judge if should forward
+ // After Nereids support group commit, we can remove
this exception
+ throw new NereidsException(new UserException("Nereids
does not support group commit insert"));
+ }
forwardToMaster();
if (masterOpExecutor != null &&
masterOpExecutor.getQueryId() != null) {
context.setQueryId(masterOpExecutor.getQueryId());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
