diff --git a/internal/indexcoord/meta_table.go b/internal/indexcoord/meta_table.go index 6aaebd39f0..d1b20dfe63 100644 --- a/internal/indexcoord/meta_table.go +++ b/internal/indexcoord/meta_table.go @@ -402,6 +402,7 @@ func (mt *metaTable) GetUnassignedTasks(onlineNodeIDs []int64) []Meta { mt.lock.RLock() defer mt.lock.RUnlock() + log.Debug("IndexCoord get unassigned tasks", zap.Int64s("online nodes", onlineNodeIDs)) var metas []Meta for _, meta := range mt.indexBuildID2Meta { @@ -425,6 +426,8 @@ func (mt *metaTable) GetUnassignedTasks(onlineNodeIDs []int64) []Meta { } } + log.Debug("IndexCoord get unassigned tasks finished", zap.Int("tasks num", len(metas))) + return metas }