Reset position variable in row_event.go to ensure correct event handling (#1049)

krajcik · lance6716 · web-flow · commit 84c5e8e28103 · 2025-07-15T19:49:36.000+08:00
Co-authored-by: lance6716 &lt;lance6716@gmail.com&gt;
diff --git a/replication/row_event.go b/replication/row_event.go
@@ -1085,6 +1085,7 @@ func (e *RowsEvent) DecodeData(pos int, data []byte) (err2 error) {
 			//nolint:nakedret
 			return
 		}
+		pos = 0
 	}
 
 	// Rows_log_event::print_verbose()

Original file line number	Diff line number	Diff line change
`@@ -1085,6 +1085,7 @@ func (e *RowsEvent) DecodeData(pos int, data []byte) (err2 error) {`
`1085`	`1085`	`//nolint:nakedret`
`1086`	`1086`	`return`
`1087`	`1087`	`}`
	`1088`	`+ pos = 0`
`1088`	`1089`	`}`
`1089`	`1090`
`1090`	`1091`	`// Rows_log_event::print_verbose()`