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 a30d69f0b1..22f05adf41 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 @@ -537,7 +537,8 @@ public class StmtExecutor { if (e instanceof NereidsException && !context.getSessionVariable().enableFallbackToOriginalPlanner && !forceFallback) { LOG.warn("Analyze failed. {}", context.getQueryIdentifier(), e); - throw ((NereidsException) e).getException(); + context.getState().setError(e.getMessage()); + return; } if (LOG.isDebugEnabled()) { LOG.debug("fall back to legacy planner on statement:\n{}", originStmt.originStmt);