[ 
https://issues.apache.org/jira/browse/NIFI-5892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723732#comment-16723732
 ] 

Koji Kawamura commented on NIFI-5892:
-------------------------------------

I think all Wait related attributes should be cleared to process the same 
FlowFile with another Wait processor. Adding a boolean property something like 
'Clear Successful Wait Attributes' with description to note that whether to 
clear wait related attributes when the FlowFiles wait activity is done, meaning 
when it gets routed to 'success'.

An alternative approach is adding a new optional processor property to specify 
'Wait Attribute Prefix'. This way, multiple Wait processors can be used for the 
same FlowFile without clearing previous attributes by separating attribute name 
spaces. Being able to keep attributes may be helpful at the subsequent flow. I 
think this approach will provide more flexibility.

> Wait timestamp lingers, potentially messing up downstream wait-notify pairs
> ---------------------------------------------------------------------------
>
>                 Key: NIFI-5892
>                 URL: https://issues.apache.org/jira/browse/NIFI-5892
>             Project: Apache NiFi
>          Issue Type: Improvement
>            Reporter: Lars Birger Aasheim
>            Assignee: Otto Fowler
>            Priority: Minor
>         Attachments: TestLingeringWaitTimestamps.xml
>
>
> The Wait processor makes use of the attribute "wait.start.timestamp" to keep 
> track of when it first encountered a flowfile. The observed behaviour is that 
> this attribute is set only if it does not exist, if else it is just checked 
> against the current time. With several wait-notify pairs in succession, there 
> is a likelihood that a flowfile will be routed directly to "expired" in one 
> of the downstream Wait processors due to a timestamp set upstream of it. I 
> suggest allowing an option of deleting the timestamp once a file is routed to 
> success (and perhaps also to expired). Currently I do this manually with an 
> UpdateAttribute processor.
>  
> Attached is a template with necessary components and also an explanation of 
> how to reproduce the issue.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to