From 193964420479ab38ba3e7d3578effc4520d61132 Mon Sep 17 00:00:00 2001 From: shaoting-huang Date: Tue, 28 May 2024 19:24:24 +0800 Subject: [PATCH] add span log for ddl Signed-off-by: shaoting-huang --- pkg/mq/msgstream/mq_msgstream.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/mq/msgstream/mq_msgstream.go b/pkg/mq/msgstream/mq_msgstream.go index 135f080cbaf31..950e3a444487e 100644 --- a/pkg/mq/msgstream/mq_msgstream.go +++ b/pkg/mq/msgstream/mq_msgstream.go @@ -373,6 +373,7 @@ func (ms *mqMsgStream) Broadcast(msgPack *MsgPack) (map[string][]MessageID, erro log.Warn("can't broadcast the msg in the backup instance", zap.Stack("stack")) return ids, merr.ErrDenyProduceMsg } + log.Ctx(ctx).Info("mq msgsteam broadcast msg size: " + strconv.Itoa(len(msgPack.Msgs))) for _, v := range msgPack.Msgs { spanCtx, sp := MsgSpanFromCtx(v.TraceCtx(), v) ctx2, sp2 := otel.Tracer(typeutil.RootCoordRole).Start(v.TraceCtx(), "Mq_msgstream-broadcast-marshal")