diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/AuditLogHelper.java b/fe/fe-core/src/main/java/org/apache/doris/qe/AuditLogHelper.java index 4184a1124b..54ea32eda7 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/AuditLogHelper.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/AuditLogHelper.java @@ -81,7 +81,11 @@ public class AuditLogHelper { ctx.getQueryDetail().setEventTime(endTime); ctx.getQueryDetail().setEndTime(endTime); ctx.getQueryDetail().setLatency(elapseMs); - ctx.getQueryDetail().setState(QueryDetail.QueryMemState.FINISHED); + if (ctx.isKilled()) { + ctx.getQueryDetail().setState(QueryDetail.QueryMemState.CANCELLED); + } else { + ctx.getQueryDetail().setState(QueryDetail.QueryMemState.FINISHED); + } QueryDetailQueue.addOrUpdateQueryDetail(ctx.getQueryDetail()); ctx.setQueryDetail(null); }