bug fix

2 years ago · b1b0733e53
parent 58c0291b7a
commit b1b0733e53
1 changed files with 1 additions and 0 deletions
--- a/parse.go
+++ b/parse.go
@ -583,6 +583,7 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter
 				currentGtid = ev.Data
 				if inGtid != nil {
 					if c, _ := inGtid.Contain(ev.Data); !c {
+						tx = Transaction{}
 						currentGtid = ""
 						skipTillNext = true
 						continue