diff --git a/internal/querynodev2/delegator/delegator_data.go b/internal/querynodev2/delegator/delegator_data.go index ab35368576..08f0389d12 100644 --- a/internal/querynodev2/delegator/delegator_data.go +++ b/internal/querynodev2/delegator/delegator_data.go @@ -760,7 +760,8 @@ func (sd *shardDelegator) loadStreamDelete(ctx context.Context, zap.Int64("segmentID", segmentID), ) sd.idfOracle.Register(segmentID, stats, segments.SegmentTypeSealed) - return false + // continue iterating to register all segments' stats + return true }) }