From 18be77af64abd0fec701de09d6574410689a369b Mon Sep 17 00:00:00 2001 From: minghong Date: Mon, 31 Oct 2022 19:02:01 +0800 Subject: [PATCH] [fix](nereids) query cannot execution when both nereids enable and fallback to legacy planner are set to false (#13787) when enable_nereids_planner=false and enable_fallback_to_origin=false, FE throws exception for all select statement. Expected: when enable_nereids_planner=false, all valid query execution success --- .../main/java/org/apache/doris/qe/ConnectProcessor.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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());