test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-01 11:29:48 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

Fix partitions may be not recovered with double load partitions (#23061)

Browse Source 
Signed-off-by: yah01 <yang.cen@zilliz.com>
This commit is contained in:
yah01 2023-03-28 21:38:02 +08:00 committed by GitHub
parent 846de72fb3
commit dc6d4b913a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
internal/querycoordv2/meta/collection_manager.go
View File

@ -101,11 +101,8 @@ func (m *CollectionManager) Recover(broker Broker) error {
for _, partition := range partitions {
// Partitions not loaded done should be deprecated
if partition.GetStatus() != querypb.LoadStatus_Loaded {
partitionIDs := lo.Map(partitions, func(partition *querypb.PartitionLoadInfo, _ int) int64 {
return partition.GetPartitionID()
})
m.store.ReleasePartition(collection, partitionIDs...)
break
m.store.ReleasePartition(collection, partition.GetPartitionID())
continue
}
m.partitions[partition.PartitionID] = &Partition{
PartitionLoadInfo: partition,