bug fix
This commit is contained in:
parent
9b9b211c0a
commit
99a7d11907
2
parse.go
2
parse.go
@ -358,8 +358,6 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter
|
|||||||
}
|
}
|
||||||
includeMap[v] = true
|
includeMap[v] = true
|
||||||
}
|
}
|
||||||
} else {
|
|
||||||
includeMap["*.*"] = true
|
|
||||||
}
|
}
|
||||||
if len(filter.ExcludeTables) != 0 {
|
if len(filter.ExcludeTables) != 0 {
|
||||||
for _, v := range filter.ExcludeTables {
|
for _, v := range filter.ExcludeTables {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user