From 76e03fe6d307477c5593f2ec39eb36122bec467f Mon Sep 17 00:00:00 2001 From: congqixia Date: Mon, 24 Jul 2023 17:07:00 +0800 Subject: [PATCH] Set reason for balance, index checker generated tasks (#25865) Signed-off-by: Congqi Xia --- internal/querycoordv2/checkers/balance_checker.go | 2 ++ internal/querycoordv2/checkers/index_checker.go | 1 + 2 files changed, 3 insertions(+) diff --git a/internal/querycoordv2/checkers/balance_checker.go b/internal/querycoordv2/checkers/balance_checker.go index 8e45949bdc..eb417ea161 100644 --- a/internal/querycoordv2/checkers/balance_checker.go +++ b/internal/querycoordv2/checkers/balance_checker.go @@ -148,9 +148,11 @@ func (b *BalanceChecker) Check(ctx context.Context) []task.Task { tasks := balance.CreateSegmentTasksFromPlans(ctx, b.ID(), Params.QueryCoordCfg.SegmentTaskTimeout.GetAsDuration(time.Millisecond), segmentPlans) task.SetPriority(task.TaskPriorityLow, tasks...) + task.SetReason("segment unbalanced", tasks...) ret = append(ret, tasks...) tasks = balance.CreateChannelTasksFromPlans(ctx, b.ID(), Params.QueryCoordCfg.ChannelTaskTimeout.GetAsDuration(time.Millisecond), channelPlans) + task.SetReason("channel unbalanced", tasks...) ret = append(ret, tasks...) return ret } diff --git a/internal/querycoordv2/checkers/index_checker.go b/internal/querycoordv2/checkers/index_checker.go index 88d0576ea5..a8d95b384f 100644 --- a/internal/querycoordv2/checkers/index_checker.go +++ b/internal/querycoordv2/checkers/index_checker.go @@ -157,5 +157,6 @@ func (c *IndexChecker) createSegmentUpdateTask(ctx context.Context, segment *met ) return nil, false } + task.SetReason("missing index") return task, true }