From d07c49da4365b08ccc0ca757f1f93066db67183b Mon Sep 17 00:00:00 2001 From: MrPresent-Han <116052805+MrPresent-Han@users.noreply.github.com> Date: Thu, 25 May 2023 19:33:28 +0800 Subject: [PATCH] [skip e2e] avoid print immense logs on input node (#24411) Signed-off-by: MrPresent-Han --- internal/util/flowgraph/input_node.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/util/flowgraph/input_node.go b/internal/util/flowgraph/input_node.go index 85dd4f1ac2..6ee4b0c8d2 100644 --- a/internal/util/flowgraph/input_node.go +++ b/internal/util/flowgraph/input_node.go @@ -83,7 +83,9 @@ func (inNode *InputNode) Operate(in []Msg) []Msg { if !ok { log.Warn("MsgStream closed", zap.Any("input node", inNode.Name())) if inNode.lastMsg != nil { - log.Info("trigger force sync", zap.Int64("collection", inNode.collectionID), zap.Any("position", inNode.lastMsg)) + log.Info("trigger force sync", zap.Int64("collection", inNode.collectionID), + zap.Any("startPositions", inNode.lastMsg.StartPositions), + zap.Any("endPositions", inNode.lastMsg.EndPositions)) return []Msg{&MsgStreamMsg{ BaseMsg: NewBaseMsg(true), tsMessages: []msgstream.TsMsg{},