[jira] [Created] (NIFI-3760) When a Processor calls ProcessSession.get(FlowFileFilter), it does not properly round-robin between incoming connections

["Mark Payne (JIRA)" <ji...@apache.org>]

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)