From 46261278f094e9bb309a6666b34836bbba82d8ce Mon Sep 17 00:00:00 2001 From: JackLCL Date: Mon, 20 Dec 2021 22:53:23 +0800 Subject: [PATCH] [skip e2e]Fix error log output format in mq_msgstream.go (#13807) Signed-off-by: JackLCL --- internal/msgstream/mq_msgstream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/msgstream/mq_msgstream.go b/internal/msgstream/mq_msgstream.go index 1a88049d08..60df0a4f01 100644 --- a/internal/msgstream/mq_msgstream.go +++ b/internal/msgstream/mq_msgstream.go @@ -995,7 +995,7 @@ func (ms *MqTtMsgStream) Seek(msgPositions []*internalpb.MsgPosition) error { headerMsg := commonpb.MsgHeader{} err := proto.Unmarshal(msg.Payload(), &headerMsg) if err != nil { - return fmt.Errorf("Failed to unmarshal message header, err %s", err.Error()) + return fmt.Errorf("failed to unmarshal message header, err %s", err.Error()) } tsMsg, err := ms.unmarshal.Unmarshal(msg.Payload(), headerMsg.Base.MsgType) if err != nil {