SYMMETRICDS-624

JumpMind · May 10, 2012 · ca8cbdb · ca8cbdb
1 parent ef3b198
commit ca8cbdb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/route/SubSelectDataRouter.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/route/SubSelectDataRouter.java
@@ -76,7 +76,8 @@ public Set<String> routeToNodes(SimpleRouterContext routingContext, DataMetaData
         TriggerRouter trigger = dataMetaData.getTriggerRouter();
         String subSelect = trigger.getRouter().getRouterExpression();
         Set<String> nodeIds = null;
-        if (!StringUtils.isBlank(subSelect)) {
+        if (!StringUtils.isBlank(subSelect) && 
+                !(initialLoad && StringUtils.isNotBlank(trigger.getInitialLoadSelect()))) {
             Map<String, Object> sqlParams = getDataObjectMap(dataMetaData, symmetricDialect);
             sqlParams.put("NODE_GROUP_ID", trigger.getRouter().getNodeGroupLink()
                     .getTargetNodeGroupId());