From 2c3a8b7dea99cdc734e5a4a471f3f8a792e2ea24 Mon Sep 17 00:00:00 2001 From: aoiasd <45024769+aoiasd@users.noreply.github.com> Date: Wed, 9 Oct 2024 12:01:20 +0800 Subject: [PATCH] enhance: fix skip msg log with empty position info (#36626) All skiped message position info was nil, should print BeginTs or MessageID instead. relate: https://github.com/milvus-io/milvus/issues/36569 Signed-off-by: aoiasd --- pkg/mq/msgstream/mq_msgstream.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/mq/msgstream/mq_msgstream.go b/pkg/mq/msgstream/mq_msgstream.go index 38f32342540c0..bf10bb3b92b4f 100644 --- a/pkg/mq/msgstream/mq_msgstream.go +++ b/pkg/mq/msgstream/mq_msgstream.go @@ -966,7 +966,8 @@ func (ms *MqTtMsgStream) Seek(ctx context.Context, msgPositions []*MsgPosition, zap.Int64("source", tsMsg.SourceID()), zap.String("type", tsMsg.Type().String()), zap.Int("size", tsMsg.Size()), - zap.Any("position", tsMsg.Position()), + zap.Uint64("msgTs", tsMsg.BeginTs()), + zap.Uint64("posTs", mp.GetTimestamp()), ) } }