From b0b0929c6c96da997563b6576312dad84359592b Mon Sep 17 00:00:00 2001 From: Bingyi Sun Date: Wed, 18 Jan 2023 17:29:43 +0800 Subject: [PATCH] Change CreateAt to UpdatedAt when checking timeout (#21769) Signed-off-by: sunby Co-authored-by: sunby --- internal/querycoordv2/observers/collection_observer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/querycoordv2/observers/collection_observer.go b/internal/querycoordv2/observers/collection_observer.go index 543ba7b75e..60bf5b98db 100644 --- a/internal/querycoordv2/observers/collection_observer.go +++ b/internal/querycoordv2/observers/collection_observer.go @@ -122,7 +122,7 @@ func (ob *CollectionObserver) observeTimeout() { ) for _, partition := range partitions { if partition.GetStatus() != querypb.LoadStatus_Loading || - time.Now().Before(partition.CreatedAt.Add(Params.QueryCoordCfg.LoadTimeoutSeconds.GetAsDuration(time.Second))) { + time.Now().Before(partition.UpdatedAt.Add(Params.QueryCoordCfg.LoadTimeoutSeconds.GetAsDuration(time.Second))) { continue }