From de1f56081eec40453933fe0ce092a20b1b3e0217 Mon Sep 17 00:00:00 2001 From: lihangyu <15605149486@163.com> Date: Fri, 1 Nov 2024 16:02:57 +0800 Subject: [PATCH] [fix](auditlog) set isQuery to true when query is short circuited (#42647) --- fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 2 ++ 1 file changed, 2 insertions(+) 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 4cab4220eef412..831696d9ebb14f 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 @@ -1846,10 +1846,12 @@ public void executeAndSendResult(boolean isOutfileQuery, boolean isSendFields, : new ShortCircuitQueryContext(planner, (Queriable) parsedStmt); coordBase = new PointQueryExecutor(shortCircuitQueryContext, context.getSessionVariable().getMaxMsgSizeOfResultReceiver()); + context.getState().setIsQuery(true); } else if (queryStmt instanceof SelectStmt && ((SelectStmt) parsedStmt).isPointQueryShortCircuit()) { // this branch is for legacy planner, to be removed coordBase = new PointQueryExec(planner, analyzer, context.getSessionVariable().getMaxMsgSizeOfResultReceiver()); + context.getState().setIsQuery(true); } else { coord = new Coordinator(context, analyzer, planner, context.getStatsErrorEstimator()); profile.addExecutionProfile(coord.getExecutionProfile());