ijokarumawak commented on issue #3538: NIFI-6385 Add option to penalize waiting 
FlowFiles
URL: https://github.com/apache/nifi/pull/3538#issuecomment-503670843
 
 
   @aramatev Yes, this PR addresses NIFI-6385. When a FlowFile is penalized, it 
won't be processed again until configured 'Penalized Duration' passes, 30 secs 
by default.
   
   So, if there are two FlowFiles attributed with `signal=a, priority=1` and 
`signal=b, priority=2` queued at 'wait' relationship which has 
PriorityPrioritizer, and signal `b` is notified, Wait processor checks 
`signal=a, priority=1` FlowFile first because it's higher priority, but signal 
`a` is not notified, then the FlowFile is penalized. At the next Wait processor 
run, `signal=b, priority=2` FlowFile get processed by Wait processor, and be 
released. Because signal `b` is already notified.
   
   I believe that addresses the use-case described by the JIRA. Am I missing 
something?

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to