From 02f4d145ca36386ae210986c6178e59bf1f13eca Mon Sep 17 00:00:00 2001 From: congqixia Date: Fri, 3 Nov 2023 01:30:16 +0800 Subject: [PATCH] Set qcv2 index task priority to Low (#28117) (#28134) Signed-off-by: Congqi Xia --- internal/querycoordv2/checkers/index_checker.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/internal/querycoordv2/checkers/index_checker.go b/internal/querycoordv2/checkers/index_checker.go index 764d2f3e5b..6f75343368 100644 --- a/internal/querycoordv2/checkers/index_checker.go +++ b/internal/querycoordv2/checkers/index_checker.go @@ -146,7 +146,7 @@ func (c *IndexChecker) getSealedSegmentsDist(replica *meta.Replica) []*meta.Segm func (c *IndexChecker) createSegmentUpdateTask(ctx context.Context, segment *meta.Segment, replica *meta.Replica) (task.Task, bool) { action := task.NewSegmentActionWithScope(segment.Node, task.ActionTypeUpdate, segment.GetInsertChannel(), segment.GetID(), querypb.DataScope_Historical) - task, err := task.NewSegmentTask( + t, err := task.NewSegmentTask( ctx, params.Params.QueryCoordCfg.SegmentTaskTimeout.GetAsDuration(time.Millisecond), c.ID(), @@ -163,6 +163,8 @@ func (c *IndexChecker) createSegmentUpdateTask(ctx context.Context, segment *met ) return nil, false } - task.SetReason("missing index") - return task, true + // index task shall have lower or equal priority than balance task + t.SetPriority(task.TaskPriorityLow) + t.SetReason("missing index") + return t, true }