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 724b7ea652..2b603710f6 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
@@ -776,8 +776,11 @@ private void insertLoadBatchesForReload(Node targetNode, long loadId, String cre
                 if (triggerRouter.getInitialLoadOrder() >= 0
                         && engine.getGroupletService().isTargetEnabled(triggerRouter, targetNode)) {
                     
-                    TableReloadRequest reloadRequest = reloadRequests.get(triggerRouter.getTriggerId() + triggerRouter.getRouterId());
-                    String selectSql = reloadRequest != null ? reloadRequest.getReloadSelect() : null;
+                    String selectSql = null;
+                    if (reloadRequests != null) {
+                        TableReloadRequest reloadRequest = reloadRequests.get(triggerRouter.getTriggerId() + triggerRouter.getRouterId());
+                        selectSql = reloadRequest != null ? reloadRequest.getReloadSelect() : null;
+                    }
                     if (StringUtils.isBlank(selectSql)) {
                         selectSql = StringUtils.isBlank(triggerRouter.getInitialLoadSelect()) 
                                     ? Constants.ALWAYS_TRUE_CONDITION