[ 
https://issues.apache.org/jira/browse/SAMZA-1021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Xinyu Liu updated SAMZA-1021:
-----------------------------
    Attachment: SAMZA-1021.0.patch

> Remove the redundent poll waiting inside AsyncRunLoop blockIfBusy
> -----------------------------------------------------------------
>
>                 Key: SAMZA-1021
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1021
>             Project: Samza
>          Issue Type: Bug
>    Affects Versions: 0.11
>            Reporter: Xinyu Liu
>            Assignee: Xinyu Liu
>             Fix For: 0.11.0
>
>         Attachments: SAMZA-1021.0.patch
>
>
> The waiting inside AsyncRunLoop is redundent given systemconsumers will block 
> on polling for empty partition. Empty partitions happens when chooser returns 
> null envelope and at the same time some task worker is avaliable to pick up 
> messages. In this case we should rely on the systemconsumers.poll() to block 
> instead of blocking in scheduling.
> The redundent waiting has been seen in our production job where both 
> choose_ns and block_ns are high at the same time.



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

Reply via email to