diff --git a/internal/querynode/meta_replica.go b/internal/querynode/meta_replica.go
index b62481ecb5..89c363bc59 100644
--- a/internal/querynode/meta_replica.go
+++ b/internal/querynode/meta_replica.go
@@ -635,15 +635,15 @@ func (replica *metaReplica) removeSegment(segmentID UniqueID, segType segmentTyp
 	case segmentTypeGrowing:
 		if segment, ok := replica.growingSegments[segmentID]; ok {
 			if collection, ok := replica.collections[segment.collectionID]; ok {
-				collection.RLock()
-				defer collection.RUnlock()
+				collection.Lock()
+				defer collection.Unlock()
 			}
 		}
 	case segmentTypeSealed:
 		if segment, ok := replica.sealedSegments[segmentID]; ok {
 			if collection, ok := replica.collections[segment.collectionID]; ok {
-				collection.RLock()
-				defer collection.RUnlock()
+				collection.Lock()
+				defer collection.Unlock()
 			}
 		}
 	default: