diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
index 24fd58cec9..7f84abdced 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -1462,6 +1462,9 @@ protected long getDataCountForReload(Table table, Node targetNode, String select
             String quote = dbInfo.getDelimiterToken();
             String catalogSeparator = dbInfo.getCatalogSeparator();
             String schemaSeparator = dbInfo.getSchemaSeparator();
+            if (selectSql != null && selectSql.trim().toUpperCase().startsWith("WHERE")) {
+                selectSql = selectSql.trim().substring(5);
+            }
             String sql = String.format("select count(*) from %s t where %s", table
                     .getQualifiedTableName(quote, catalogSeparator, schemaSeparator), selectSql);
             sql = FormatUtils.replace("groupId", targetNode.getNodeGroupId(), sql);