diff --git a/internal/datanode/flow_graph_insert_buffer_node.go b/internal/datanode/flow_graph_insert_buffer_node.go
index 400180c422b946f43e29ced56f426b80be7b5040..03c303fdd5d7ef371a8b61254ee09a1f185036e8 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))