diff --git a/internal/querycoord/task_scheduler.go b/internal/querycoord/task_scheduler.go index a55fdc46b3..5fd9a0ac96 100644 --- a/internal/querycoord/task_scheduler.go +++ b/internal/querycoord/task_scheduler.go @@ -597,7 +597,7 @@ func (scheduler *TaskScheduler) scheduleLoop() { childTaskKeys = append(childTaskKeys, taskKey) childTaskKeys = append(childTaskKeys, stateKey) err := scheduler.client.MultiRemove(childTaskKeys) - // after recover, child Task's state will be TaskDone, will not be repeat executed + // after recover, child Task's state will be TaskDone, will not be repeatedly executed if err != nil { panic(err) }