[jira] [Created] (NIFI-6093) SplitRecord processor doesn't propagate fragment* attributes to original relationship

["Dmitry Mashkov (JIRA)" <ji...@apache.org>]

Dmitry Mashkov created NIFI-6093:
------------------------------------

             Summary: 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


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 should 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)