From e3e99ca5e6e41993dc70a6c44db71307d9a7d8fe Mon Sep 17 00:00:00 2001 From: Mark Payne Date: Wed, 22 Feb 2017 17:02:56 -0500 Subject: [PATCH] NIFI-3522: When creating a clone of a FlowFile, ensure that we properly set the 'updated attributes' on the RepositoryRecord to all attributes on the FlowFile itself, the same way we do when calling create(FlowFile) --- .../nifi/controller/repository/StandardProcessSession.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java index 16a6534410bc..fe99fb3aa8b8 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-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. emptyMap()); + record.setWorking(clone, clone.getAttributes()); records.put(clone, record); if (offset == 0L && size == example.getSize()) {