From 53734bef58616ae465ef05d80fc313fe9d505127 Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Fri, 8 Jul 2022 10:18:28 +0800 Subject: [PATCH] Add seek msgID in DataNode (#17881) Signed-off-by: yangxuan --- internal/datanode/flow_graph_dmstream_input_node.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/datanode/flow_graph_dmstream_input_node.go b/internal/datanode/flow_graph_dmstream_input_node.go index a755371e9..86979098b 100644 --- a/internal/datanode/flow_graph_dmstream_input_node.go +++ b/internal/datanode/flow_graph_dmstream_input_node.go @@ -51,12 +51,12 @@ func newDmInputNode(ctx context.Context, seekPos *internalpb.MsgPosition, dmNode if seekPos != nil { seekPos.ChannelName = pchannelName start := time.Now() - log.Info("datanode begin to seek", zap.String("physical channel", seekPos.GetChannelName()), zap.Int64("collection ID", dmNodeConfig.collectionID)) + log.Info("datanode begin to seek", zap.ByteString("seek msgID", seekPos.GetMsgID()), zap.String("physical channel", seekPos.GetChannelName()), zap.Int64("collection ID", dmNodeConfig.collectionID)) err = insertStream.Seek([]*internalpb.MsgPosition{seekPos}) if err != nil { return nil, err } - log.Info("datanode seek successfully", zap.String("physical channel", seekPos.GetChannelName()), zap.Int64("collection ID", dmNodeConfig.collectionID), zap.Duration("elapse", time.Since(start))) + log.Info("datanode seek successfully", zap.ByteString("seek msgID", seekPos.GetMsgID()), zap.String("physical channel", seekPos.GetChannelName()), zap.Int64("collection ID", dmNodeConfig.collectionID), zap.Duration("elapse", time.Since(start))) } name := fmt.Sprintf("dmInputNode-data-%d-%s", dmNodeConfig.collectionID, dmNodeConfig.vChannelName) -- GitLab