diff --git a/internal/querynode/collection_replica.go b/internal/querynode/collection_replica.go index 41dc5a64eb..0b18a5deb0 100644 --- a/internal/querynode/collection_replica.go +++ b/internal/querynode/collection_replica.go @@ -148,6 +148,7 @@ func (colReplica *collectionReplica) addCollection(collectionID UniqueID, schema return nil } +// removeCollection removes the collection from collectionReplica func (colReplica *collectionReplica) removeCollection(collectionID UniqueID) error { colReplica.mu.Lock() defer colReplica.mu.Unlock()