We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9cf5c72 commit 8734b3fCopy full SHA for 8734b3f
worker/draft.go
@@ -936,7 +936,10 @@ func (n *node) processApplyCh() {
936
case proposal.Mutations != nil:
937
tags = append(tags, tag.Upsert(x.KeyMethod, "apply.Mutations"))
938
span.SetAttributes(attribute.Int64("start_ts", int64(proposal.Mutations.StartTs)))
939
- posting.Oracle().GetTxn(proposal.Mutations.StartTs).Span = span
+ txn := posting.Oracle().GetTxn(proposal.Mutations.StartTs)
940
+ if txn != nil {
941
+ txn.Span = span
942
+ }
943
944
case proposal.Delta != nil:
945
tags = append(tags, tag.Upsert(x.KeyMethod, "apply.Delta"))
0 commit comments