milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[skip e2e]Add log for reducing results in querynode (#13972) 

Signed-off-by: Cai.Zhang <cai.zhang@zilliz.com>
pull/14016/head
cai.zhang 2021-12-22 20:47:08 +08:00 committed by GitHub
parent 289e11323d
commit 3418c17d90
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/querynode/query_collection.go
View File

@ -1095,9 +1095,12 @@ func (q *queryCollection) search(msg queryMsg) error {
numSegment := int64(len(searchResults))
var marshaledHits *MarshaledHits
log.Debug("QueryNode reduce data", zap.Int64("msgID", searchMsg.ID()), zap.Int64("numSegment", numSegment))
err = reduceSearchResultsAndFillData(plan, searchResults, numSegment)
log.Debug("QueryNode reduce data finished", zap.Int64("msgID", searchMsg.ID()))
sp.LogFields(oplog.String("statistical time", "reduceSearchResults end"))
if err != nil {
log.Error("QueryNode reduce data failed", zap.Int64("msgID", searchMsg.ID()), zap.Error(err))
return err
}
marshaledHits, err = reorganizeSearchResults(searchResults, numSegment)