[
https://issues.apache.org/jira/browse/FLINK-14097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17329664#comment-17329664
]
Flink Jira Bot commented on FLINK-14097:
----------------------------------------
This issue has been labeled "stale-minor" for 7 days. It is closed now. If you
are still affected by this or would like to raise the priority of this ticket
please re-open, removing the label "auto-closed" and raise the ticket priority
accordingly.
> Optimize AsyncWaitOperator to process more than one element per mailbox letter
> ------------------------------------------------------------------------------
>
> Key: FLINK-14097
> URL: https://issues.apache.org/jira/browse/FLINK-14097
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Task
> Reporter: Alex
> Priority: Minor
> Labels: stale-minor
>
> With the changes introduced in FLINK-12958, the results (output) of
> {{AsyncWaitOperator}} are handled via {{StreamTask}}'s mailbox letter (a
> letter action per one input element).
> This may degrade performance of the operator: before, the emitter thread was
> emitting elements directly to operator's output as soon as results were ready.
> This is a follow up ticket, to address this concern.
> Potential workaround can be to (non-blockingly) dequeue more ready results
> from {{StreamElementQueue}} in one mailbox action.
> *Note:* this can also be incorporated in FLINK-14044.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
