[
https://issues.apache.org/jira/browse/APEXCORE-570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824455#comment-15824455
]
Pramod Immaneni commented on APEXCORE-570:
------------------------------------------
"Consider the case of two subscribers with same throughput but different
pattern. Once with constant and capped rate, other with bursts of activity. If
they are forced to read at the same rate, then both will be slower and overall
throughput reduce? Granted this is not the common scenario, but something to
consider."
Yes it would result in a slower throughput but since the operator is controlled
by a single thread I think back pressure over one stream will block the other.
> 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)
