diff --git a/internal/querynode/collection_replica.go b/internal/querynode/collection_replica.go index 6a6dab6561..4cd5e9d1fc 100644 --- a/internal/querynode/collection_replica.go +++ b/internal/querynode/collection_replica.go @@ -133,6 +133,7 @@ func (colReplica *collectionReplica) getCollectionIDs() []UniqueID { return collectionIDs } +// addCollection creates a new collection and add it to collectionReplica func (colReplica *collectionReplica) addCollection(collectionID UniqueID, schema *schemapb.CollectionSchema) error { colReplica.mu.Lock() defer colReplica.mu.Unlock()