Repository: nifi Updated Branches: refs/heads/master cefc02c5f -> 64379d200
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) This closes #1532 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/64379d20 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/64379d20 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/64379d20 Branch: refs/heads/master Commit: 64379d2007ab7d6976783d104c451fdd8ff0556d Parents: cefc02c Author: Mark Payne <[email protected]> Authored: Wed Feb 22 17:02:56 2017 -0500 Committer: Oleg Zhurakousky <[email protected]> Committed: Wed Feb 22 17:16:14 2017 -0500 ---------------------------------------------------------------------- .../apache/nifi/controller/repository/StandardProcessSession.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/64379d20/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java ---------------------------------------------------------------------- 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 16a6534..fe99fb3 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 final class StandardProcessSession implements ProcessSession, ProvenanceE 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()) {
