[jira] [Comment Edited] (APEXCORE-570) Prevent upstream operators from getting too far ahead when downstream operators are slow

["David Yan (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/APEXCORE-570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15630848#comment-15630848 ] 

David Yan edited comment on APEXCORE-570 at 11/2/16 11:11 PM:
--------------------------------------------------------------

[~PramodSSImmaneni] Maybe we can't block it but can't we suspend the call to emitTuples and also suspend the window from being progressed until a commit happens if the spool reaches  capacity?


was (Author: davidyan):
[~PramodSSImmaneni] Maybe we can't block it but can't we suspend the call to emitTuples and also suspend the window from being progressed until a commit happens if the spool reaches the capacity?

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