From b1b0733e53da2939b4f1b2d66d6e6e7695724469 Mon Sep 17 00:00:00 2001
From: starainrt <i@b612.me>
Date: Mon, 3 Jul 2023 17:36:00 +0800
Subject: [PATCH] bug fix

---
 parse.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/parse.go b/parse.go
index d3337d8..5d62306 100644
--- 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