diff --git a/internal/querycoordv2/checkers/balance_checker.go b/internal/querycoordv2/checkers/balance_checker.go index 399e7c03ff..6c6727fabc 100644 --- a/internal/querycoordv2/checkers/balance_checker.go +++ b/internal/querycoordv2/checkers/balance_checker.go @@ -43,6 +43,9 @@ func (b *BalanceChecker) Description() string { func (b *BalanceChecker) Check(ctx context.Context) []task.Task { ret := make([]task.Task, 0) + if !Params.QueryCoordCfg.AutoBalance.GetAsBool() { + return ret + } segmentPlans, channelPlans := b.Balance.Balance() tasks := balance.CreateSegmentTasksFromPlans(ctx, b.ID(), Params.QueryCoordCfg.SegmentTaskTimeout.GetAsDuration(time.Millisecond), segmentPlans)