From 0e26486abc2ec137df1b103857dee1977754662c Mon Sep 17 00:00:00 2001 From: wei liu Date: Tue, 25 Jul 2023 09:13:00 +0800 Subject: [PATCH] fix segment num in log (#25876) Signed-off-by: Wei Liu --- internal/querynodev2/delegator/delegator.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/internal/querynodev2/delegator/delegator.go b/internal/querynodev2/delegator/delegator.go index b9d23e372f..07c54104d5 100644 --- a/internal/querynodev2/delegator/delegator.go +++ b/internal/querynodev2/delegator/delegator.go @@ -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)