diff --git a/internal/rootcoord/import_manager.go b/internal/rootcoord/import_manager.go index b0fcd878f0..2c815949f2 100644 --- a/internal/rootcoord/import_manager.go +++ b/internal/rootcoord/import_manager.go @@ -122,7 +122,6 @@ func (m *importManager) sendOutTasksLoop(wg *sync.WaitGroup) { log.Debug("import manager context done, exit check sendOutTasksLoop") return case <-ticker.C: - log.Debug("sending out tasks") m.sendOutTasks(m.ctx) } } diff --git a/internal/rootcoord/root_coord.go b/internal/rootcoord/root_coord.go index 6e44db6b70..824c4e8b39 100644 --- a/internal/rootcoord/root_coord.go +++ b/internal/rootcoord/root_coord.go @@ -1468,7 +1468,7 @@ func (c *Core) DescribeCollection(ctx context.Context, in *milvuspb.DescribeColl tr := timerecord.NewTimeRecorder("DescribeCollection") log.Debug("DescribeCollection", zap.String("role", typeutil.RootCoordRole), - zap.String("collection name", in.CollectionName), zap.Int64("msgID", in.Base.MsgID)) + zap.String("collection name", in.CollectionName), zap.Int64("id", in.CollectionID), zap.Int64("msgID", in.Base.MsgID)) t := &DescribeCollectionReqTask{ baseReqTask: baseReqTask{ ctx: ctx, @@ -1480,14 +1480,14 @@ func (c *Core) DescribeCollection(ctx context.Context, in *milvuspb.DescribeColl err := executeTask(t) if err != nil { log.Error("DescribeCollection failed", zap.String("role", typeutil.RootCoordRole), - zap.String("collection name", in.CollectionName), zap.Int64("msgID", in.Base.MsgID), zap.Error(err)) + zap.String("collection name", in.CollectionName), zap.Int64("id", in.CollectionID), zap.Int64("msgID", in.Base.MsgID), zap.Error(err)) metrics.RootCoordDDLReqCounter.WithLabelValues("DescribeCollection", metrics.FailLabel).Inc() return &milvuspb.DescribeCollectionResponse{ Status: failStatus(commonpb.ErrorCode_UnexpectedError, "DescribeCollection failed: "+err.Error()), }, nil } log.Debug("DescribeCollection success", zap.String("role", typeutil.RootCoordRole), - zap.String("collection name", in.CollectionName), zap.Int64("msgID", in.Base.MsgID)) + zap.String("collection name", in.CollectionName), zap.Int64("id", in.CollectionID), zap.Int64("msgID", in.Base.MsgID)) metrics.RootCoordDDLReqCounter.WithLabelValues("DescribeCollection", metrics.SuccessLabel).Inc() metrics.RootCoordDDLReqLatency.WithLabelValues("DescribeCollection").Observe(float64(tr.ElapseSpan().Milliseconds()))