From f5fa93aa0b6b3aca0691d23dd48932d4c3cb4ffb Mon Sep 17 00:00:00 2001 From: yah01 Date: Fri, 17 Jun 2022 12:42:11 +0800 Subject: [PATCH] Return err if failed to assign segments/channels to nodes (#17616) Signed-off-by: yah01 --- internal/querycoord/task.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/querycoord/task.go b/internal/querycoord/task.go index 78011c8568..3cd2644324 100644 --- a/internal/querycoord/task.go +++ b/internal/querycoord/task.go @@ -2051,6 +2051,7 @@ func (lbt *loadBalanceTask) processNodeDownLoadBalance(ctx context.Context) erro if err != nil { log.Error("loadBalanceTask: assign child task failed", zap.Int64("sourceNodeID", nodeID)) lbt.setResultInfo(err) + return err } internalTasks = append(internalTasks, tasks...) }