[jira] [Commented] (APEXCORE-353) Buffer server may stop processing data

["Vlad Rozov (JIRA)" <ji...@apache.org>]

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

Vlad Rozov commented on APEXCORE-353:
-------------------------------------

Buffer server has single threaded execution service that is responsible for processing data on all datalists. This thread iterates over datalist and submits data to netlet to be sent downstream. In case downstream operator (or unifier) is not capable of keeping up with incoming stream of data, this thread will be blocked re-trying to send data to the downstream operator, so data in other datalists/output streams will be waiting for the thread to become available. In case downstream operator waits for that data (for example it may wait for BEGIN or END window) before continuing with processing data on the initial stream (the one that currently is served by the thread), bufferserver will completely stop sending data to downstream operators.

> Buffer server may stop processing data
> --------------------------------------
>
>                 Key: APEXCORE-353
>                 URL: https://issues.apache.org/jira/browse/APEXCORE-353
>             Project: Apache Apex Core
>          Issue Type: Bug
>    Affects Versions: 3.2.0, 3.3.0, 3.4.0, 3.3.1
>            Reporter: Vlad Rozov
>            Assignee: Vlad Rozov
>
> When an operator has two or more output ports and one of output ports produces large number of tuples, the bufferserver may stop sending data to downstream operators.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)