[jira] [Updated] (FLINK-14097) Optimize AsyncWaitOperator to process more than one element per mailbox letter

["Piotr Nowojski (Jira)" <ji...@apache.org>]

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

Piotr Nowojski updated FLINK-14097:
-----------------------------------
        Parent:     (was: FLINK-12477)
    Issue Type: Improvement  (was: Sub-task)

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