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...)
 		}