diff --git a/src/main/java/com/zendesk/maxwell/schema/MysqlSchemaStore.java b/src/main/java/com/zendesk/maxwell/schema/MysqlSchemaStore.java index db2511eff..d97858641 100644 --- a/src/main/java/com/zendesk/maxwell/schema/MysqlSchemaStore.java +++ b/src/main/java/com/zendesk/maxwell/schema/MysqlSchemaStore.java @@ -19,7 +19,6 @@ public class MysqlSchemaStore extends AbstractSchemaStore implements SchemaStore private final ConnectionPool maxwellConnectionPool; private final Position initialPosition; private final boolean readOnly; - private final Filter filter; private Long serverID; private MysqlSavedSchema savedSchema; @@ -34,7 +33,6 @@ public MysqlSchemaStore(ConnectionPool maxwellConnectionPool, boolean readOnly) { super(replicationConnectionPool, schemaConnectionPool, caseSensitivity, filter); this.serverID = serverID; - this.filter = filter; this.maxwellConnectionPool = maxwellConnectionPool; this.initialPosition = initialPosition; this.readOnly = readOnly;