Mark Payne created NIFI-13914:
---------------------------------

             Summary: Stateless not honoring ProcessSession.transfer ordering
                 Key: NIFI-13914
                 URL: https://issues.apache.org/jira/browse/NIFI-13914
             Project: Apache NiFi
          Issue Type: Bug
          Components: Core Framework
    Affects Versions: 2.0.0-M4, 2.0.0-M3, 2.0.0-M2, 2.0.0-M1
            Reporter: Mark Payne
            Assignee: Mark Payne


Occasionally a Processor operates on a batch of FlowFiles instead of a single 
FlowFile. If it transfers the FlowFiles in a particular order, the Process 
Session is not honoring that ordering in stateless, which can result in the 
next processor receiving the data in the wrong order. For example, a source 
Processor might receive two FlowFiles in a single session and transfer the 
first, then the second, using `ProcessSession.transfer(FlowFile, 
Relationship)`. In this case, the ProcessSession properly updates the last 
queue date/index. But when the FlowFiles are transferred to the next 
StatelessFlowFileQueue, they are not provided in any particular order, and the 
stateless flowfile queue simply adds them in whatever order the given 
Collection iterates over them. This results in data being improperly re-ordered 
within a Stateless execution.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to