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)