From 59bc0a70006816a053f8f873bcce61c924df5d12 Mon Sep 17 00:00:00 2001 From: Bingyi Sun Date: Mon, 16 May 2022 17:15:55 +0800 Subject: [PATCH] Add some log. (#16978) Signed-off-by: sunby Co-authored-by: sunby --- internal/querycoord/task.go | 4 +++- internal/querycoord/task_scheduler.go | 5 ++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/internal/querycoord/task.go b/internal/querycoord/task.go index e5ebb37e92..80e6176e5a 100644 --- a/internal/querycoord/task.go +++ b/internal/querycoord/task.go @@ -2278,7 +2278,9 @@ func (lbt *loadBalanceTask) globalPostExecute(ctx context.Context) error { log.Debug("removing offline nodes from replicas and segments...", zap.Int("len(replicas)", len(replicas)), - zap.Int("len(segments)", len(segments))) + zap.Int("len(segments)", len(segments)), + zap.Int64("trigger task ID", lbt.getTaskID()), + ) wg := sync.WaitGroup{} for _, replica := range replicas { wg.Add(1) diff --git a/internal/querycoord/task_scheduler.go b/internal/querycoord/task_scheduler.go index 4f3338e1cf..0d54314c0b 100644 --- a/internal/querycoord/task_scheduler.go +++ b/internal/querycoord/task_scheduler.go @@ -576,7 +576,10 @@ func (scheduler *TaskScheduler) scheduleLoop() { var triggerTask task processInternalTaskFn := func(activateTasks []task, triggerTask task) { - log.Debug("scheduleLoop: num of child task", zap.Int("num child task", len(activateTasks))) + log.Debug("scheduleLoop: num of child task", + zap.Int("num child task", len(activateTasks)), + zap.Int64("trigger task ID", triggerTask.getTaskID()), + ) for _, childTask := range activateTasks { if childTask != nil { log.Debug("scheduleLoop: add an activate task to activateChan", zap.Int64("taskID", childTask.getTaskID()))