diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/AbstractTransformer.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/AbstractTransformer.java
index 0775909da8..26fc36d361 100644
--- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/AbstractTransformer.java
+++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/AbstractTransformer.java
@@ -180,7 +180,7 @@ protected List<TransformedData> create(ICacheContext context, DmlType dmlType,
                 for (TransformedData data : datas) {
                     try {
                         Object columnValue = transformColumn(context, data, transformColumn,
-                                sourceKeyValues, oldSourceValues);
+                                sourceValues, oldSourceValues);
                         if (columnValue instanceof String) {
                             data.put(transformColumn, (String) columnValue, true);
                         } else if (columnValue instanceof List) {