diff --git a/internal/querynode/collection_replica.go b/internal/querynode/collection_replica.go index 917694e183..daef6731f0 100644 --- a/internal/querynode/collection_replica.go +++ b/internal/querynode/collection_replica.go @@ -131,6 +131,7 @@ type collectionReplica struct { etcdKV *etcdkv.EtcdKV } +// queryLock guards query and delete operations func (colReplica *collectionReplica) queryLock() { colReplica.queryMu.Lock() }