From 61a5b15ada0ef3ad36ebb91bbcbce24fc106570b Mon Sep 17 00:00:00 2001 From: wei liu Date: Mon, 11 Nov 2024 14:34:28 +0800 Subject: [PATCH] fix: Lost loading collection's updateTs after qc restart (#37538) issue: #37537 Signed-off-by: Wei Liu --- internal/querycoordv2/meta/collection_manager.go | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/internal/querycoordv2/meta/collection_manager.go b/internal/querycoordv2/meta/collection_manager.go index 085bc901e89db..4a6f2ef7fd61c 100644 --- a/internal/querycoordv2/meta/collection_manager.go +++ b/internal/querycoordv2/meta/collection_manager.go @@ -169,9 +169,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 { @@ -187,13 +189,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) }