[NIFI-1155] Processor stops running if its destination applies backpressure and expiration occurs

• Type: Bug
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 0.4.0
• Fix Version/s: 0.4.0
• Component/s: Core Framework
• Assignee: Mark Payne
• Reporter: Mark Payne
• Created: 12/Nov/15 01:42
• Updated: 13/Nov/15 12:34
• Resolved: 13/Nov/15 05:18

Description

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.