Alex created FLINK-14097:
----------------------------
Summary: 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: Sub-task
Components: Runtime / Task
Reporter: Alex
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.2#803003)
