From cf9d99f79f78fbe64cca5cb0ffc3e1dae3a7f80d Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Tue, 11 Oct 2022 10:17:23 +0800 Subject: [PATCH] Fix reduce latency metric (#19479) (#19488) Signed-off-by: bigsheeper Co-authored-by: wgcn <1026688210@qq.com> Co-authored-by: wgcn <1026688210@qq.com> --- internal/querynode/task_search.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/internal/querynode/task_search.go b/internal/querynode/task_search.go index d1287aeb2e..386a653d83 100644 --- a/internal/querynode/task_search.go +++ b/internal/querynode/task_search.go @@ -223,7 +223,11 @@ func (s *searchTask) reduceResults(searchReq *searchRequest, results []*SearchRe log.Debug("marshal for historical results error", zap.Int64("msgID", s.ID()), zap.Error(err)) return err } - defer deleteSearchResultDataBlobs(blobs) + + defer func() { + deleteSearchResultDataBlobs(blobs) + s.reduceDur = s.tr.RecordSpan() + }() for i := 0; i < cnt; i++ { blob, err := getSearchResultDataBlob(blobs, i) @@ -266,8 +270,9 @@ func (s *searchTask) reduceResults(searchReq *searchRequest, results []*SearchRe SlicedNumCount: 1, } } + + s.reduceDur = s.tr.RecordSpan() } - s.reduceDur = s.tr.RecordSpan() return nil }