diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/TransformedData.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/TransformedData.java
index 9afc93a2b0..e69745657e 100644
--- a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/TransformedData.java
+++ b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/TransformedData.java
@@ -332,7 +332,7 @@ private void addOldValue(List<String> keyNames, List<String> keyValues, List<Str
         } else {
             String transformType = transformColumn.getTransformType();
             String sourceColumnName = transformColumn.getSourceColumnName();
-            if (CopyColumnTransform.NAME.equals(transformType) && 
+            if (transformType!=null && transformType.startsWith(CopyColumnTransform.NAME) && 
                     oldSourceValues.containsKey(sourceColumnName)) {                
                 values.add(oldSourceValues.get(sourceColumnName));
                 return;