detect ddl based on normalized table name
diff --git a/changes.go b/changes.go index e9be041..a3a39b5 100644 --- a/changes.go +++ b/changes.go
@@ -289,7 +289,7 @@ } for _, change := range changes { - if !a[change.Table] { + if !a[normalizeTableName(change.Table)] { log.Infof("Unable to find %s table in current known tables", change.Table) return true }