From 217ed38bb47795e9e39e9ab6b934597d7c33227b Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Thu, 21 Sep 2023 10:03:31 +0800 Subject: [PATCH] Improve FlushChannels log (#27265) Signed-off-by: bigsheeper --- internal/datacoord/session_manager.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/datacoord/session_manager.go b/internal/datacoord/session_manager.go index 2c6942dab5..03207fc6c0 100644 --- a/internal/datacoord/session_manager.go +++ b/internal/datacoord/session_manager.go @@ -33,6 +33,7 @@ import ( "github.com/milvus-io/milvus/pkg/util/commonpbutil" "github.com/milvus-io/milvus/pkg/util/paramtable" "github.com/milvus-io/milvus/pkg/util/retry" + "github.com/milvus-io/milvus/pkg/util/tsoutil" "github.com/milvus-io/milvus/pkg/util/typeutil" ) @@ -302,13 +303,16 @@ func (c *SessionManager) GetCompactionState() map[int64]*datapb.CompactionStateR } func (c *SessionManager) FlushChannels(ctx context.Context, nodeID int64, req *datapb.FlushChannelsRequest) error { - log := log.Ctx(ctx).With(zap.Int64("nodeID", nodeID)) + log := log.Ctx(ctx).With(zap.Int64("nodeID", nodeID), + zap.Time("flushTs", tsoutil.PhysicalTime(req.GetFlushTs())), + zap.Strings("channels", req.GetChannels())) cli, err := c.getClient(ctx, nodeID) if err != nil { log.Warn("failed to get client", zap.Error(err)) return err } + log.Info("SessionManager.FlushChannels start") resp, err := cli.FlushChannels(ctx, req) err = VerifyResponse(resp, err) if err != nil {