diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractTriggerTemplate.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractTriggerTemplate.java
index e670ccaaa6..cb9159b5c7 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractTriggerTemplate.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/db/AbstractTriggerTemplate.java
@@ -169,7 +169,7 @@ public String createInitalLoadSql(Node node, TriggerRouter triggerRouter, Table
             }            
             sql = FormatUtils.replace("columns", columnsText, sql);
         } else {            
-            sql = "select $(schemaName)$(columns) from $(tableName) t where $(whereClause)";
+            sql = "select $(columns) from $(schemaName)$(tableName) t where $(whereClause)";
             StringBuilder columnList = new StringBuilder();
             for (int i = 0; i < columns.length; i++) {
                 Column column = columns[i];