Details
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.
Attachments
Issue Links
- relates to
-
NIFI-2848 Queues aren't fairly drained when leading to a single component
-
- Resolved
-
- links to