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
 		}