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
 }