[ https://issues.apache.org/jira/browse/FLINK-14044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Arvid Heise updated FLINK-14044: -------------------------------- Component/s: Runtime / Task > Reducing synchronization in AsyncWaitOperator > --------------------------------------------- > > Key: FLINK-14044 > URL: https://issues.apache.org/jira/browse/FLINK-14044 > Project: Flink > Issue Type: Improvement > Components: Runtime / Task > Reporter: Arvid Heise > Priority: Major > > Currently, AsyncWaitOperator receives computed results from a user thread and > puts it in {{StreamElementQueue}}. This queue is synchronized as the emitter > thread pulls available elements in a blocking fashion. With the recent > migration to mailbox model, these elements are then put into a letter to be > outputted in the mailbox thread. > If we directly send the results from the user thread to the mailbox, we can > get rid of any synchronization as everything happens in the user thread. That > will slim down the code heavily. -- This message was sent by Atlassian Jira (v8.3.2#803003)