bug fix

2 years ago · 1ed514f350
parent 6eecb93b9c
commit 1ed514f350
1 changed files with 1 additions and 1 deletions
--- a/parse.go
+++ b/parse.go
@ -447,7 +447,7 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter
 		if filter.SmallThan != 0 && filter.SmallThan < tx.Size {
 			return true
 		}
-		if tx.validSchemaCount == 0 {
+		if !filter.OnlyShowGtid && tx.validSchemaCount == 0 {
 			return true
 		}
 		return fn(tx)