[FLINK-12958] Integrate AsyncWaitOperator with mailbox

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: Stefan Richter
• Created: 24/Jun/19 08:35
• Updated: 20/Sep/19 12:26
• Resolved: 17/Sep/19 11:57

Description

Currently, the AsyncWaitOperator::processElement() is running in the main task thread and blocks in addAsyncBufferEntry() when adding a new element in the full StreamElementQueue.

The blocking of the main task thread prevents progress of mailbox events handling. The approach via FLINK-13248 may help process the events while queue is full.

Issue Links

• links to: GitHub Pull Request #9426