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 c457a5fecc..74d9a63365 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 @@ -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());