From 14b15098614f82615b7990e5a11b74bfa1f48e07 Mon Sep 17 00:00:00 2001
From: luwei16 <814383175@qq.com>
Date: Thu, 10 Nov 2022 19:33:29 +0800
Subject: [PATCH] Fix the bug of not updating the query latency metric

---
 .../src/main/java/org/apache/doris/qe/ConnectProcessor.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 38e37052fd8df2..90cd2b9ec4897c 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
@@ -189,7 +189,8 @@ private void auditAfterExec(String origStmt, StatementBase parsedStmt, Data.PQue
                     && ctx.getState().getErrType() != QueryState.ErrType.ANALYSIS_ERR) {
                 // err query
                 MetricRepo.COUNTER_QUERY_ERR.increase(1L);
-            } else if (ctx.getState().getStateType() == MysqlStateType.OK) {
+            } else if (ctx.getState().getStateType() == MysqlStateType.OK
+                    || ctx.getState().getStateType() == MysqlStateType.EOF) {
                 // ok query
                 MetricRepo.HISTO_QUERY_LATENCY.update(elapseMs);
                 MetricRepo.DB_HISTO_QUERY_LATENCY.getOrAdd(ctx.getDatabase()).update(elapseMs);