Skip to content

Commit

Permalink
add span log for ddl
Browse files Browse the repository at this point in the history
Signed-off-by: shaoting-huang <[email protected]>
  • Loading branch information
shaoting-huang committed May 28, 2024
1 parent 00bade7 commit 1939644
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions pkg/mq/msgstream/mq_msgstream.go
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down

0 comments on commit 1939644

Please sign in to comment.