Re: FlowFile position when transferred to Relationship.SELF

2017-07-10 Thread Koji Kawamura
Hi Ben, FIFO prioritizer uses lastQueueDate, and when a FlowFile is transferred to SELF, lastQueueDate will be updated, so I think FIFO may not work as you expect. https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-standard-prioritizers/src/main/j

Re: FlowFile position when transferred to Relationship.SELF

2017-07-10 Thread 尹文才
Hi Koji, thanks for the explanation, I checked the NIFI documentation you provided, do you mean I should use the FIFO prioritizer in my case? Because as you mentioned the FlowFiles would be put back into their original positions, so as I understand using FIFO should make the FlowFiles in consisten

Re: FlowFile position when transferred to Relationship.SELF

2017-07-10 Thread Koji Kawamura
Hi, I think it puts back a FlowFile to its original position but update queued date as implemented here: https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.j