From b99ac973d25c0d1aabfb4de49d73f5b928686d95 Mon Sep 17 00:00:00 2001 From: Nitin-Kashyap <66766227+Nitin-Kashyap@users.noreply.github.com> Date: Tue, 19 Dec 2023 15:14:15 +0530 Subject: [PATCH] [fix](meta) update killed query state (#) (#25917) --- .../src/main/java/org/apache/doris/qe/AuditLogHelper.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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); }