[
https://issues.apache.org/jira/browse/NIFI-6093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819034#comment-16819034
]
ASF subversion and git services commented on NIFI-6093:
-------------------------------------------------------
Commit d0224f78970b8f30ae63f698f0a22239f22f1f9a in nifi's branch
refs/heads/master from Matt Burgess
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=d0224f7 ]
NIFI-6093: Add count and id fragment attributes to original FlowFile in
SplitRecord
This closes #3435.
Signed-off-by: Mark Payne <[email protected]>
> SplitRecord processor doesn't propagate fragment* attributes to original
> relationship
> -------------------------------------------------------------------------------------
>
> Key: NIFI-6093
> URL: https://issues.apache.org/jira/browse/NIFI-6093
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 1.9.0
> Reporter: Dmitry Mashkov
> Assignee: Matt Burgess
> Priority: Major
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Hello Team,
> As I already described in summary, SplitRecord processor missed fragment*
> attributes as result it is impossible to use Wait/Notify pattern to wait
> splits processing.
> I think follow patch can be applied
> {code:java}
> Index:
> nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitRecord.java
> IDEA additional info:
> Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
> <+>UTF-8
> ===================================================================
> ---
> nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitRecord.java
> (date 1550371815000)
> +++
> nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/SplitRecord.java
> (date 1551441180000)
> @@ -206,7 +206,8 @@
> return;
> }
> - session.transfer(original, REL_ORIGINAL);
> + final FlowFile originalFlowFile =
> FragmentAttributes.copyAttributesToOriginal(session, original, fragmentId,
> splits.size());
> + session.transfer(originalFlowFile, REL_ORIGINAL);
> // Add the fragment count to each split
> for(FlowFile split : splits) {
> session.putAttribute(split, FRAGMENT_COUNT, String.valueOf(splits.size()));
> {code}
>
> Sincerely,
> Dmitry.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
