[FLINK-12479] Make InputProcessors and StreamIterationHead non-blocking

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Piotr Nowojski
• Reporter: Stefan Richter
• Created: 10/May/19 09:38
• Updated: 08/Aug/19 10:54
• Resolved: 08/Aug/19 10:54

Description

After decomposing the monolith loops in the previous sub-task, we need to change the implementations of certain actions, e.g. in {{InputProcessor}}s to be non-blocking, so that they will not stall the mailbox processing in the future.

Issue Links

• links to: GitHub Pull Request #8826