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 44c88c6b9b..c9c9b34cbd 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 @@ -294,13 +294,13 @@ public class ConnectProcessor { auditInfoList.add(new Pair<>(executor.getParsedStmt(), executor.getQueryStatisticsForAuditLog())); } - // audit after exec + // audit after exec, analysis query would not be recorded if (!auditInfoList.isEmpty()) { for (Pair audit : auditInfoList) { auditAfterExec(originStmt.replace("\n", " "), audit.first, audit.second); } - } else { - // auditInfoList can be empty if we encounter analysis error. + } else if (QueryState.ErrType.ANALYSIS_ERR != ctx.getState().getErrType()) { + // auditInfoList can be empty if we encounter error. auditAfterExec(originStmt.replace("\n", " "), null, null); } if (executor != null) {