NIFI-3522: When creating a clone of a FlowFile, ensure that we proper…

…ly set the 'updated attributes' on the RepositoryRecord to all attributes on the FlowFile itself, the same way we do when calling create(FlowFile) This closes apache#1532
nexr · Feb 22, 2017 · 64379d2 · 64379d2
1 parent cefc02c
commit 64379d2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...work-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java b/...work-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
@@ -1631,7 +1631,7 @@ public FlowFile clone(final FlowFile example, final long offset, final long size
             context.getContentRepository().incrementClaimaintCount(claim);
         }
         final StandardRepositoryRecord record = new StandardRepositoryRecord(null);
-        record.setWorking(clone, Collections.<String, String> emptyMap());
+        record.setWorking(clone, clone.getAttributes());
         records.put(clone, record);
 
         if (offset == 0L && size == example.getSize()) {