diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
index 1c518495dc..bab6c692a7 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -1713,7 +1713,7 @@ protected Table lookupAndOrderColumnsAccordingToTriggerHistory(String routerId,
     }
 
     protected String replaceVariables(Node sourceNode, Node targetNode, String str) {
-        str = FormatUtils.replace("sourceNodeId", sourceNode.getNodeGroupId(), str);
+        str = FormatUtils.replace("sourceNodeId", sourceNode.getNodeId(), str);
         str = FormatUtils.replace("sourceExternalId", sourceNode.getExternalId(), str);
         str = FormatUtils.replace("sourceNodeGroupId", sourceNode.getNodeGroupId(), str);
         str = FormatUtils.replace("targetNodeId", targetNode.getNodeGroupId(), str);