ijokarumawak commented on issue #3344: NIFI-6092 Create ListenSlack and 
FetchSlack processors
URL: https://github.com/apache/nifi/pull/3344#issuecomment-473121612
 
 
   @szaboferee Just wanted to share that the current style doesn't take the 
outgoing connection's back-pressure configuration into account.
   
   Meaning, even if I configured 'Back Pressure Object Threshold' to 10, 
ListenSlack keeps generating FlowFiles after exceeding the threshold.
   
   NiFi flow engine stops scheduling further onTrigger for the upstream 
processors if the connection meets its back-pressure threshold. But since 
ListenSlack generates FlowFiles at ControllerService instead of processor's 
onTrigger, FlowFiles are generated.
   
   In contrast, ListenTCP implements internal blocking queue to hold received 
bytes. Then its onTrigger creates FlowFiles. This model can work with NiFi 
back-pressure mechanism better.
   
![image](https://user-images.githubusercontent.com/1107620/54400460-42f15980-4706-11e9-8f16-a7b9b5968bfe.png)
   
   I think that's acceptable to submit another JIRA to adopt this later.
   

----------------------------------------------------------------
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