Normalize dmInputNode seek log (#9714)

Signed-off-by: N Congqi Xia <congqi.xia@zilliz.com>

Normalize dmInputNode seek log (#9714)
Signed-off-by: N Congqi Xia <congqi.xia@zilliz.com>
d8f49008 · congqixia · GitHub · e9d2d0b1 · d8f49008
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

internal/datanode/flow_graph_dmstream_input_node.go internal/datanode/flow_graph_dmstream_input_node.go +1 -1

未找到文件。
--- a/internal/datanode/flow_graph_dmstream_input_node.go
+++ b/internal/datanode/flow_graph_dmstream_input_node.go
@@ -46,7 +46,7 @@ func newDmInputNode(ctx context.Context, factory msgstream.Factory, collID Uniqu

 	if seekPos != nil {
 		seekPos.ChannelName = pchannelName
-		log.Debug("datanode Seek: " + seekPos.GetChannelName())
+		log.Debug("datanode Seek", zap.String("channelName", seekPos.GetChannelName()))
 		err = insertStream.Seek([]*internalpb.MsgPosition{seekPos})
 		if err != nil {
 			return nil, err