diff --git a/internal/querynode/collection_replica.go b/internal/querynode/collection_replica.go index b547b2a362..66b7b77a3f 100644 --- a/internal/querynode/collection_replica.go +++ b/internal/querynode/collection_replica.go @@ -547,6 +547,7 @@ func (colReplica *collectionReplica) removeExcludedSegments(collectionID UniqueI delete(colReplica.excludedSegments, collectionID) } +// addExcludedSegments will add excludedSegments to collectionReplica func (colReplica *collectionReplica) addExcludedSegments(collectionID UniqueID, segmentInfos []*datapb.SegmentInfo) { colReplica.mu.Lock() defer colReplica.mu.Unlock()