Vstreamer: idempotent gtid set (bugfix) (#18611)

shlomi-noach · web-flow · commit aa9ff484a45f · 2025-08-31T13:41:27.000Z
Signed-off-by: Shlomi Noach &lt;2607934+shlomi-noach@users.noreply.github.com&gt;
diff --git a/go/vt/vttablet/tabletserver/vstreamer/vstreamer.go b/go/vt/vttablet/tabletserver/vstreamer/vstreamer.go
@@ -491,7 +491,7 @@ func (vs *vstreamer) parseEvent(ev mysql.BinlogEvent, bufferAndTransmit func(vev
 				SequenceNumber: sequenceNumber,
 			})
 		}
-		vs.pos = replication.AppendGTIDInPlace(vs.pos, gtid)
+		vs.pos = replication.AppendGTID(vs.pos, gtid)
 		vs.commitParent = commitParent
 		vs.sequenceNumber = sequenceNumber
 		vs.eventGTID = gtid

Original file line number	Diff line number	Diff line change
`@@ -491,7 +491,7 @@ func (vs *vstreamer) parseEvent(ev mysql.BinlogEvent, bufferAndTransmit func(vev`
`491`	`491`	`SequenceNumber: sequenceNumber,`
`492`	`492`	`})`
`493`	`493`	`}`
`494`		`- vs.pos = replication.AppendGTIDInPlace(vs.pos, gtid)`
	`494`	`+ vs.pos = replication.AppendGTID(vs.pos, gtid)`
`495`	`495`	`vs.commitParent = commitParent`
`496`	`496`	`vs.sequenceNumber = sequenceNumber`
`497`	`497`	`vs.eventGTID = gtid`