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

ASF subversion and git services commented on NIFI-12228:
--------------------------------------------------------

Commit 4d00f8e1563ffec40d8d601ac2b678ad0414bb5b in nifi's branch 
refs/heads/support/nifi-1.x from Mark Payne
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=4d00f8e156 ]

NIFI-12228: This closes #7882. Fixed issue with FlowFile Concucrrency that can 
occasionally bring in more data than it should.

Signed-off-by: Joseph Witt <[email protected]>


> Concurrency bug can occasionally lead to allowing a group with Single 
> FlowFile per Node input pulling in multiple FlowFiles
> ---------------------------------------------------------------------------------------------------------------------------
>
>                 Key: NIFI-12228
>                 URL: https://issues.apache.org/jira/browse/NIFI-12228
>             Project: Apache NiFi
>          Issue Type: Bug
>            Reporter: Mark Payne
>            Assignee: Mark Payne
>            Priority: Major
>             Fix For: 1.latest, 2.latest
>
>          Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> Every now and then we see a failure in the system tests:
> {code:java}
> BatchFlowBetweenGroupsIT.testSingleConcurrencyAndBatchOutputToBatchInputOutput
>  ยป Timeout testSingleConcurrencyAndBatchOutputToBatchInputOutput() timed out 
> after 5 minutes {code}
> Looking at the logs shows that this is happening because data enters Group A, 
> and then before the Output Port has a chance to push the data out of Group A, 
> a second FlowFile enters. As a result, the test fails because the queue 
> between Groups A and B, or the connection inside of Group B, never reach the 
> expected size.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to