From cf40bb9b5c799bc5d55ef8418c9a7db58546109e Mon Sep 17 00:00:00 2001 From: bigsheeper Date: Fri, 30 Dec 2022 15:37:31 +0800 Subject: [PATCH] Improve datacoord log (#21453) Signed-off-by: bigsheeper --- internal/datacoord/services.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/datacoord/services.go b/internal/datacoord/services.go index 2578118cd7..a551a3d495 100644 --- a/internal/datacoord/services.go +++ b/internal/datacoord/services.go @@ -124,7 +124,7 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F zap.Int64("collectionID", req.GetCollectionID()), zap.Int64s("sealSegments", sealedSegmentIDs), zap.Int64s("flushSegments", flushSegmentIDs), - zap.Int64("timeOfSeal", timeOfSeal.Unix())) + zap.Time("timeOfSeal", timeOfSeal)) resp.Status.ErrorCode = commonpb.ErrorCode_Success resp.DbID = req.GetDbID() resp.CollectionID = req.GetCollectionID() @@ -1136,7 +1136,7 @@ func (s *Server) GetFlushState(ctx context.Context, req *milvuspb.GetFlushStateR } if len(unflushed) != 0 { - log.Info("DataCoord receive GetFlushState request, Flushed is false", zap.Int64s("segmentIDs", unflushed), zap.Int("len", len(unflushed))) + log.RatedInfo(10, "DataCoord receive GetFlushState request, Flushed is false", zap.Int64s("segmentIDs", unflushed), zap.Int("len", len(unflushed))) resp.Flushed = false } else { log.Info("DataCoord receive GetFlushState request, Flushed is true", zap.Int64s("segmentIDs", req.GetSegmentIDs()), zap.Int("len", len(req.GetSegmentIDs())))