mirror of
https://gitee.com/milvus-io/milvus.git
synced 2026-02-02 01:06:41 +08:00
parent
9e8b6ace6d
commit
25c96991f6
@ -182,9 +182,11 @@ func (m *CollectionManager) Recover(broker Broker) error {
|
||||
}
|
||||
}
|
||||
|
||||
m.collections[collection.CollectionID] = &Collection{
|
||||
// update collection's CreateAt and UpdateAt to now after qc restart
|
||||
m.putCollection(false, &Collection{
|
||||
CollectionLoadInfo: collection,
|
||||
}
|
||||
CreatedAt: time.Now(),
|
||||
})
|
||||
}
|
||||
|
||||
for collection, partitions := range partitions {
|
||||
@ -200,13 +202,19 @@ func (m *CollectionManager) Recover(broker Broker) error {
|
||||
}
|
||||
|
||||
partition.RecoverTimes += 1
|
||||
m.putPartition([]*Partition{{PartitionLoadInfo: partition}}, true)
|
||||
m.putPartition([]*Partition{
|
||||
{
|
||||
PartitionLoadInfo: partition,
|
||||
CreatedAt: time.Now(),
|
||||
},
|
||||
}, true)
|
||||
continue
|
||||
}
|
||||
|
||||
m.putPartition([]*Partition{
|
||||
{
|
||||
PartitionLoadInfo: partition,
|
||||
CreatedAt: time.Now(),
|
||||
},
|
||||
}, false)
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user