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

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

     [ https://issues.apache.org/jira/browse/NIFI-3760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Mark Payne updated NIFI-3760:
-----------------------------
    Fix Version/s: 1.2.0
           Status: Patch Available  (was: Open)

> 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
>             Fix For: 1.2.0
>
>
> 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)