diff --git a/internal/querynode/collection_replica.go b/internal/querynode/collection_replica.go
index a4dc1671b5..c05bc9439d 100644
--- a/internal/querynode/collection_replica.go
+++ b/internal/querynode/collection_replica.go
@@ -387,9 +387,11 @@ func (colReplica *collectionReplica) addPartitionPrivate(collectionID UniqueID,
 		return err
 	}
 
-	collection.addPartitionID(partitionID)
-	var newPartition = newPartition(collectionID, partitionID)
-	colReplica.partitions[partitionID] = newPartition
+	if !colReplica.hasPartitionPrivate(partitionID) {
+		collection.addPartitionID(partitionID)
+		var newPartition = newPartition(collectionID, partitionID)
+		colReplica.partitions[partitionID] = newPartition
+	}
 	return nil
 }