In JdbcTable the following lines should changed: sqlDeletaMarkDeleteByDelta = sb.append("delete from ").append(getQualifiedName()) .append(" where ").append(deletedColumn.getQuotedName()).append(" = ?") .append("and ").append(lastModifiedColumn.getQuotedName()).append(" < ?").toString(); to: sqlDeletaMarkDeleteByDelta = sb.append("delete from ").append(getQualifiedName()) .append(" where ").append(deletedColumn.getQuotedName()).append(" = ?") .append(" and ").append(lastModifiedColumn.getQuotedName()).append(" < ?").toString(); NOTE: Additional space before 'and' at the last row. The MySQL JDBC driver is unable to parse request without the space correctly.