From 038f42851e735c2ff2086b5467bbb0d0f35d1c22 Mon Sep 17 00:00:00 2001 From: Bingyi Sun Date: Thu, 18 Nov 2021 10:37:41 +0800 Subject: [PATCH] Add more log for debug (#11893) Signed-off-by: sunby Co-authored-by: sunby --- internal/datanode/flow_graph_insert_buffer_node.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/datanode/flow_graph_insert_buffer_node.go b/internal/datanode/flow_graph_insert_buffer_node.go index 400180c42..03c303fdd 100644 --- a/internal/datanode/flow_graph_insert_buffer_node.go +++ b/internal/datanode/flow_graph_insert_buffer_node.go @@ -208,6 +208,7 @@ func (ibNode *insertBufferNode) Operate(in []Msg) []Msg { } if len(seg2Upload) > 0 { + log.Debug("flowgraph insert buffer node consumed msgs with end position", zap.String("channel", ibNode.channelName), zap.Any("end position", endPositions[0])) err := ibNode.uploadMemStates2Coord(seg2Upload) if err != nil { log.Error("upload segment statistics to coord error", zap.Error(err)) -- GitLab