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

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.2.0
• Component/s: Core Framework
• Assignee: Joe Witt
• Reporter: Mark Payne
• Created: 28/Apr/17 18:12
• Updated: 02/May/17 05:04
• Resolved: 02/May/17 05:04

Description

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.

Issue Links

• links to: GitHub Pull Request #1717