[ 
https://issues.apache.org/jira/browse/NIFI-2751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15659509#comment-15659509
 ] 

Pierre Villard commented on NIFI-2751:
--------------------------------------

[~markap14], I just submitted a PR to address this case. Not sure to clearly 
see why we are trying to pull a batch of flow files without having incoming 
connections, though. I guess this is a special situation, no? Anyway, always 
better to prevent a division by zero!

> When a processor pulls a batch of FlowFiles, it keeps pulling from the same 
> inbound connection instead of round-robin'ing
> -------------------------------------------------------------------------------------------------------------------------
>
>                 Key: NIFI-2751
>                 URL: https://issues.apache.org/jira/browse/NIFI-2751
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Core Framework
>            Reporter: Mark Payne
>            Assignee: Pierre Villard
>            Priority: Blocker
>              Labels: beginner, easyfix, framework, newbie
>             Fix For: 1.1.0
>
>
> 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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to