diff --git a/internal/querynode/collection_replica.go b/internal/querynode/collection_replica.go index a7eec381fe..7c988d1f76 100644 --- a/internal/querynode/collection_replica.go +++ b/internal/querynode/collection_replica.go @@ -423,6 +423,7 @@ func (colReplica *collectionReplica) setSegment(segment *Segment) error { return colReplica.addSegmentPrivate(segment.segmentID, segment.partitionID, segment) } +// removeSegment removes a segment from collectionReplica func (colReplica *collectionReplica) removeSegment(segmentID UniqueID) error { colReplica.mu.Lock() defer colReplica.mu.Unlock()