diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java
index 22d135f693..347bb598d7 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java
@@ -166,7 +166,9 @@ private void recordSyncNeeded(DataContext context, Table table, CsvData data) {
                 Map<String, String> newData = data.toColumnNameValuePairs(table.getColumnNames(), CsvData.ROW_DATA);
                 String initialLoadEnabled = newData.get("INITIAL_LOAD_ENABLED");
                 String initialLoadTime = newData.get("INITIAL_LOAD_TIME");
-                if (StringUtils.isNotBlank(initialLoadTime) && "0".equals(initialLoadEnabled)) {
+                String nodeId = newData.get("NODE_ID");
+                if (nodeId != null && nodeId.equals(context.getBatch().getTargetNodeId()) &&
+                        StringUtils.isNotBlank(initialLoadTime) && "0".equals(initialLoadEnabled)) {
                     log.info(
                             "Requesting syncTriggers because {} is false and sym_node_security changed to indicate that an initial load has completed",
                             ParameterConstants.TRIGGER_CREATE_BEFORE_INITIAL_LOAD);