From 8bdff401a3ab2fa8336f3534d6e287d2f14e869a Mon Sep 17 00:00:00 2001 From: Xianhui Lin <35839735+JsDove@users.noreply.github.com> Date: Thu, 20 Mar 2025 18:05:22 +0800 Subject: [PATCH] fix: fix indexchecker schema released (#40809) pr:https://github.com/milvus-io/milvus/pull/38039 issue:https://github.com/milvus-io/milvus/issues/36995 Signed-off-by: Xianhui.Lin --- internal/querycoordv2/checkers/index_checker.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/internal/querycoordv2/checkers/index_checker.go b/internal/querycoordv2/checkers/index_checker.go index 3e19f7db85..f4eb8a8b6a 100644 --- a/internal/querycoordv2/checkers/index_checker.go +++ b/internal/querycoordv2/checkers/index_checker.go @@ -97,10 +97,6 @@ func (c *IndexChecker) Check(ctx context.Context) []task.Task { log.Warn("collection released during check index", zap.Int64("collection", collectionID)) continue } - if schema == nil { - log.Warn("schema released during check index", zap.Int64("collection", collectionID)) - continue - } replicas := c.meta.ReplicaManager.GetByCollection(ctx, collectionID) for _, replica := range replicas { tasks = append(tasks, c.checkReplica(ctx, collection, replica, indexInfos, schema)...) @@ -240,8 +236,11 @@ func (c *IndexChecker) createSegmentUpdateTask(ctx context.Context, segment *met func (c *IndexChecker) checkSegmentStats(segment *meta.Segment, schema *schemapb.CollectionSchema, loadField []int64) (missFieldIDs []int64) { var result []int64 - if paramtable.Get().CommonCfg.EnabledJSONKeyStats.GetAsBool() { + if schema == nil { + log.Warn("schema released during check checkSegmentStats", zap.Int64("collection", segment.GetCollectionID())) + return result + } loadFieldMap := make(map[int64]struct{}) for _, v := range loadField { loadFieldMap[v] = struct{}{}