From 266d54bb39d35ade8ab529fce76db77ea8d78897 Mon Sep 17 00:00:00 2001 From: GoGoWen <82132356+GoGoWen@users.noreply.github.com> Date: Sun, 9 Apr 2023 20:09:16 +0800 Subject: [PATCH] [Refine](sql block)unify exception catching for sql block (#17879) currently, the AnalysisException throw by matchSql will catch immediately. however, the AnalysisException throws by checkLimitations will catch as UserException. --- .../main/java/org/apache/doris/qe/StmtExecutor.java | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) 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 20a684836d..9592c2b832 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 @@ -464,14 +464,8 @@ public class StmtExecutor implements ProfileWriter { } private boolean checkBlockRules() throws AnalysisException { - try { - Env.getCurrentEnv().getSqlBlockRuleMgr().matchSql( - originStmt.originStmt, context.getSqlHash(), context.getQualifiedUser()); - } catch (AnalysisException e) { - LOG.warn(e.getMessage()); - context.getState().setError(e.getMysqlErrorCode(), e.getMessage()); - return true; - } + Env.getCurrentEnv().getSqlBlockRuleMgr().matchSql( + originStmt.originStmt, context.getSqlHash(), context.getQualifiedUser()); // limitations: partition_num, tablet_num, cardinality List scanNodeList = planner.getScanNodes();