Mark Payne created NIFI-3760:
--------------------------------

             Summary: When a Processor calls 
ProcessSession.get(FlowFileFilter), it does not properly round-robin between 
incoming connections
                 Key: NIFI-3760
                 URL: https://issues.apache.org/jira/browse/NIFI-3760
             Project: Apache NiFi
          Issue Type: Bug
          Components: Core Framework
            Reporter: Mark Payne
            Assignee: Mark Payne


If ProcessSession.get() or ProcessSession.get(int) is called, it uses the 
ProcessContext's getNextIncomingConnectionIndex() method to determine which 
connection to use. However, the ProcessSession.get(FlowFileFilter) method 
iterates over all connections and doesn't necessarily start at the 'next' 
connection. So if we have a lot of data in one connection, that connection will 
starve out the others.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to