You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Andy LoPresto (JIRA)" <ji...@apache.org> on 2018/08/14 01:43:00 UTC

[jira] [Commented] (NIFI-4805) allow delayed transfer

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

Andy LoPresto commented on NIFI-4805:
-------------------------------------

I almost opened what I think is a duplicate of this today; I was going to propose a {{Sleep}} processor which takes a configurable property as the delay time and just waits to release the flowfile. I think it should support Expression Language and in the context of the penalization, maybe a counter of the number of times this flowfile has been penalized so that exponential backoff like Martin described above could work. 

> allow delayed transfer
> ----------------------
>
>                 Key: NIFI-4805
>                 URL: https://issues.apache.org/jira/browse/NIFI-4805
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Core Framework
>            Reporter: Martin Mucha
>            Priority: Minor
>         Attachments: retry.xml
>
>
> Nifi has concept of penalization, but this penalization has fixed delay, and there isn't way how to change it dynamically. 
> If we want to implement retry flow, where FlowFile flows in loop, we can either lower performance of Processor via yielding it, or we can do active waiting. And this is actually recommended as a correct way how to do that.
> It seems, that we can easily implement better RetryProcessor, all we missing is `session.penalize` which accepts `penalizationPeriod`. Processor then can gradually prolong waiting time after each failure.
>  
> Would it be possible to make such method visible?



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