[
https://issues.apache.org/jira/browse/NIFI-12228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775055#comment-17775055
]
ASF subversion and git services commented on NIFI-12228:
--------------------------------------------------------
Commit 0eabbcdf19dfa9de7085b4b173ac3d3260f9d3a4 in nifi's branch
refs/heads/main from Mark Payne
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=0eabbcdf19 ]
NIFI-12228: This closes #7881. Fixed issue with FlowFile Concucrrency that can
occasionally bring in more data than it should.
Code cleanup, fixing logback to avoid INFO-level stack trace from xodus
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: 20m
> 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)
