[ https://issues.apache.org/jira/browse/NIFI-3760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989704#comment-15989704 ]
Joseph Witt commented on NIFI-3760: ----------------------------------- reviewing. > 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: Joseph Witt > 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)