diff --git a/internal/indexcoord/task_scheduler.go b/internal/indexcoord/task_scheduler.go index e419d9d20a..b80fc71065 100644 --- a/internal/indexcoord/task_scheduler.go +++ b/internal/indexcoord/task_scheduler.go @@ -299,6 +299,8 @@ func (sched *TaskScheduler) Start() error { // Close closes the task scheduler of indexing tasks. func (sched *TaskScheduler) Close() { - sched.cancel() + if sched.cancel != nil { + sched.cancel() + } sched.wg.Wait() }