test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-02 11:59:00 +08:00
Code Issues Actions 12 Packages Projects Releases Wiki Activity

Add log for search (#12625)

Browse Source 
Signed-off-by: Cai.Zhang <cai.zhang@zilliz.com>
This commit is contained in:
cai.zhang 2021-12-07 09:54:01 +08:00 committed by GitHub
parent b97e88e859
commit ed58c277e3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/querynode/query_collection.go
View File

@ -977,6 +977,7 @@ func (q *queryCollection) search(msg queryMsg) error {
searchResults := make([]*SearchResult, 0)
// historical search
log.Debug("historical search start", zap.Int64("msgID", msg.ID()))
hisSearchResults, sealedSegmentSearched, err := q.historical.search(searchRequests, collection.id, searchMsg.PartitionIDs, plan, travelTimestamp)
if err != nil {
return err
@ -984,6 +985,7 @@ func (q *queryCollection) search(msg queryMsg) error {
searchResults = append(searchResults, hisSearchResults...)
tr.Record("historical search done")
log.Debug("streaming search start", zap.Int64("msgID", msg.ID()))
for _, channel := range collection.getVChannels() {
var strSearchResults []*SearchResult
strSearchResults, err := q.streaming.search(searchRequests, collection.id, searchMsg.PartitionIDs, channel, plan, travelTimestamp)