@ -491,7 +491,7 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter
}
if !matched {
if matched {
tx.Txs = txs
if len(tx.Txs) == 0 && matched {