From 1ed514f35087bdece4032098e0502b0f105db579 Mon Sep 17 00:00:00 2001 From: starainrt Date: Mon, 3 Jul 2023 15:16:36 +0800 Subject: [PATCH] bug fix --- parse.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parse.go b/parse.go index 678490f..4bb417a 100644 --- 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)