[ https://issues.apache.org/jira/browse/FLINK-14097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Konstantin Knauf updated FLINK-14097: ------------------------------------- Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > 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: Not a Priority > > 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)