diff --git a/internal/querycoordv2/task/utils.go b/internal/querycoordv2/task/utils.go index e895f6af5d..23fce606b6 100644 --- a/internal/querycoordv2/task/utils.go +++ b/internal/querycoordv2/task/utils.go @@ -198,7 +198,6 @@ func fillSubChannelRequest( ) error { segmentIDs := typeutil.NewUniqueSet() for _, vchannel := range req.GetInfos() { - segmentIDs.Insert(vchannel.GetFlushedSegmentIds()...) segmentIDs.Insert(vchannel.GetUnflushedSegmentIds()...) }