database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](group commit) Fix group commit connect to observer fe (#32222)

Browse Source
This commit is contained in:
meiyi
2024-03-19 19:52:20 +08:00
committed by yiguolei
parent 14c9537679
commit 3c377a8957
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
View File

@ -608,6 +608,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());