[NIFI-2751] When a processor pulls a batch of FlowFiles, it keeps pulling from the same inbound connection instead of round-robin'ing

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Core Framework
• Labels: beginner easyfix framework newbie
• Assignee: Pierre Villard
• Reporter: Mark Payne
• Created: 09/Sep/16 17:19
• Updated: 15/Nov/16 21:20
• Resolved: 15/Nov/16 21:20

Description

When a Processor calls ProcessSession.get(int) or ProcessSession.get(FlowFileFilter), the FlowFiles only come from the first inbound connection, unless that connection is empty or doesn't have enough FlowFiles to complete the get() call. It should instead round-robin between the incoming connections, just as ProcessSession.get() does.

Issue Links

• relates to: NIFI-2848 Queues aren't fairly drained when leading to a single component
• links to: GitHub Pull Request #1111
• links to: GitHub Pull Request #1211