Koji Kawamura created NIFI-4028:
-----------------------------------
Summary: Wait processor removes cache regardless of the remaing
counter
Key: NIFI-4028
URL: https://issues.apache.org/jira/browse/NIFI-4028
Project: Apache NiFi
Issue Type: Bug
Components: Extensions
Affects Versions: 1.2.0
Reporter: Koji Kawamura
Assignee: Koji Kawamura
Current [Wait processor implementation removes cache
entry|https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/Wait.java#L438]
if it's configured with 'Releasable FlowFile Count' is one, when it finds a
wait signal reaches to 'Target Signal Count' no matter how large the current
count is.
This behavior can be problematic, when an user expects the same Signal
Identifier to be released multiple FlowFiles one by one while multiple counts
to be accumulated by Notify.
For example this scenario does not work:
{code}
1. Notify notifies to a 'signal-a' + 1 => 'signal-a' = 1
2. Notify notifies to a 'signal-a' again, +1 => 'signal-a' = 2
3. Wait releases 1 FlowFile, then remove the 'signal-a' => 'signal-a' is removed
4. Wait will not be able to release another FlowFile
{code}
This should be fixed as follows:
{code}
1. Notify notifies to a 'signal-a' + 1 => 'signal-a' = 1
2. Notify notifies to a 'signal-a' again, +1 => 'signal-a' = 2
3. Wait releases 1 FlowFile, then update the 'signal-a', -1 => 'signal-a' = 1
4. Wait releases another FlowFile, then 'signal-a' becomes 0, remove 'signal-a'
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
