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