[
https://issues.apache.org/jira/browse/APEXCORE-570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15628460#comment-15628460
]
Pramod Immaneni commented on APEXCORE-570:
------------------------------------------
Here is an example on how to do this from within the application
https://github.com/PramodSSImmaneni/throttle
In this JIRA the idea is to do this within the engine in the bufferserver
itself to allow a configurable option to limit how far the upstream operator
can get ahead of the downstream operator in terms of number of windows before
it is blocked. Once the downstream catches up the upstream operator data will
be unblocked.
> Prevent upstream operators from getting too far ahead when downstream
> operators are slow
> ----------------------------------------------------------------------------------------
>
> Key: APEXCORE-570
> URL: https://issues.apache.org/jira/browse/APEXCORE-570
> Project: Apache Apex Core
> Issue Type: Improvement
> Reporter: Pramod Immaneni
> Assignee: Pramod Immaneni
>
> If the downstream operators are slower than upstream operators then the
> upstream operators will get ahead and the gap can continue to increase.
> Provide an option to slow down or temporarily pause the upstream operators
> when they get too far ahead.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
