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