diff --git a/internal/querynode/collection_replica.go b/internal/querynode/collection_replica.go index 1b62e404fb..e29cf4f601 100644 --- a/internal/querynode/collection_replica.go +++ b/internal/querynode/collection_replica.go @@ -309,6 +309,7 @@ func (colReplica *collectionReplica) removePartitionPrivate(partitionID UniqueID return nil } +// getPartitionByID returns the partition which id is partitionID func (colReplica *collectionReplica) getPartitionByID(partitionID UniqueID) (*Partition, error) { colReplica.mu.RLock() defer colReplica.mu.RUnlock()