0003470: Table reload request for specific tables causes sync triggers

to run
JumpMind · Mar 1, 2018 · 72b8fbf · 72b8fbf
1 parent ac70c3d
commit 72b8fbf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...e/src/main/java/org/jumpmind/symmetric/load/ConfigurationChangedDatabaseWriterFilter.java b/...e/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);