You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by "Joseph Witt (JIRA)" <ji...@apache.org> on 2015/11/13 02:51:11 UTC
[jira] [Commented] (NIFI-1155) Processor stops running if its
destination applies backpressure and expiration occurs
[ https://issues.apache.org/jira/browse/NIFI-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15003394#comment-15003394 ]
Joseph Witt commented on NIFI-1155:
-----------------------------------
will dive in now
> Processor stops running if its destination applies backpressure and expiration occurs
> -------------------------------------------------------------------------------------
>
> Key: NIFI-1155
> URL: https://issues.apache.org/jira/browse/NIFI-1155
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 0.4.0
> Reporter: Mark Payne
> Assignee: Mark Payne
> Priority: Blocker
> Fix For: 0.4.0
>
> Attachments: 0001-NIFI-1155-Ensure-that-when-poll-FlowFileFilter-Set-i.patch, 0002-NIFI-1155-Refactored-StandardFlowFileQueue-to-update.patch
>
>
> If we setup a flow where Processor A is connected to Processor B and set backpressure to say 200 FlowFiles, all works well. If we then apply an ageoff (say 15 seconds) and start the Processors, all works well.
> Then stop Processor B so that the queue applies backpressure.
> Leave Processor B stopped long enough for the expiration to occur.
> The queue is now emptied, but Processor A does not continue to run.
> It appears that when FlowFiles are expired while the queue is full, the queue still thinks it is full.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)