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

fix segment num in log (#25876) 

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
pull/25884/head
wei liu 2023-07-25 09:13:00 +08:00 committed by GitHub
parent 53c3bf053e
commit 0e26486abc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/querynodev2/delegator/delegator.go
View File

@ -239,6 +239,12 @@ func (sd *shardDelegator) Search(ctx context.Context, req *querypb.SearchRequest
if req.Req.IgnoreGrowing {
growing = []SegmentEntry{}
}
sealedNum := lo.SumBy(sealed, func(item SnapshotItem) int { return len(item.Segments) })
log.Info("search segments...",
zap.Int("sealedNum", sealedNum),
zap.Int("growingNum", len(growing)),
)
tasks, err := organizeSubTask(req, sealed, growing, sd.workerManager, sd.modifySearchRequest)
if err != nil {
log.Warn("Search organizeSubTask failed", zap.Error(err))
@ -298,8 +304,9 @@ func (sd *shardDelegator) Query(ctx context.Context, req *querypb.QueryRequest)
growing = []SegmentEntry{}
}
sealedNum := lo.SumBy(sealed, func(item SnapshotItem) int { return len(item.Segments) })
log.Info("query segments...",
zap.Int("sealedNum", len(sealed)),
zap.Int("sealedNum", sealedNum),
zap.Int("growingNum", len(growing)),
)
tasks, err := organizeSubTask(req, sealed, growing, sd.workerManager, sd.modifyQueryRequest)