diff --git a/internal/indexcoord/index_coord.go b/internal/indexcoord/index_coord.go index 162bb03176..f22c386e23 100644 --- a/internal/indexcoord/index_coord.go +++ b/internal/indexcoord/index_coord.go @@ -293,12 +293,6 @@ func (i *IndexCoord) BuildIndex(ctx context.Context, req *indexpb.BuildIndexRequ kv: i.kv, } - if i.nodeClients == nil || i.nodeClients.Len() <= 0 { - ret.Status.Reason = "IndexBuilding Service not available" - return ret, nil - } - t.nodeClients = i.nodeClients - var cancel func() t.ctx, cancel = context.WithTimeout(ctx, reqTimeoutInterval) defer cancel() diff --git a/internal/indexcoord/task.go b/internal/indexcoord/task.go index 74bd68a328..72984c96a4 100644 --- a/internal/indexcoord/task.go +++ b/internal/indexcoord/task.go @@ -77,7 +77,6 @@ type IndexAddTask struct { buildQueue TaskQueue kv kv.BaseKV builderClient types.IndexNode - nodeClients *PriorityQueue buildClientNodeID UniqueID }