[ https://issues.apache.org/jira/browse/NIFI-122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14957126#comment-14957126 ]
Mark Payne commented on NIFI-122: --------------------------------- This work has been addressed as a part of a larger effort, NIFI-730. > FlowFileQueue should block if queue is too full > ----------------------------------------------- > > Key: NIFI-122 > URL: https://issues.apache.org/jira/browse/NIFI-122 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework > Reporter: Matt Gilman > Fix For: 0.4.0 > > > If data comes in at extremely high rates, it's possible that the FlowFiles > will not be swapped out quickly enough. This can lead to OOME. Instead, the > FlowFileQueue should set a limit to the queue size and block when attempting > to offer a new FlowFile until either the consuming component consumes the > data or the data is swapped out via the Swap Manager (MUST ensure that we do > not block while holding lock!) -- This message was sent by Atlassian JIRA (v6.3.4#6332)