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 847bb5baf0..38e37052fd 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 @@ -282,10 +282,11 @@ public class ConnectProcessor { ctx.resetReturnRows(); } parsedStmt = stmts.get(i); - if (parsedStmt instanceof SelectStmt) { - if (!ctx.getSessionVariable().enableFallbackToOriginalPlanner) { - throw new Exception(String.format("SQL: %s", parsedStmt.toSql()), nereidsParseException); - } + if (parsedStmt instanceof SelectStmt && nereidsParseException != null + && ctx.getSessionVariable().isEnableNereidsPlanner() + && !ctx.getSessionVariable().enableFallbackToOriginalPlanner) { + throw new Exception(String.format("nereids cannot anaylze sql, and fall-back disabled: %s", + parsedStmt.toSql()), nereidsParseException); } parsedStmt.setOrigStmt(new OriginStatement(originStmt, i)); parsedStmt.setUserInfo(ctx.getCurrentUserIdentity());