[FLINK-15750] Execute network flushing actions in the mailbox instead of OutputFlusher

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Affects Version/s: 1.10.0
• Component/s: Runtime / Network
• Labels: auto-unassigned pull-request-available stale-major
• Assignee: Unassigned
• Reporter: Piotr Nowojski
• Created: 24/Jan/20 11:08
• Updated: 23/Sep/21 17:26
• Resolved: 21/Jun/21 07:37

Description

Currently almost all interactions with the network stack are happening from the mailbox thread, except of org.apache.flink.runtime.io.network.api.writer.ResultPartitionWriter#flushAll, which happens from OutputFlusher thread.

We could move ResultPartitionWriter#flushAll to happen in the mailbox thread (as a mailbox action), which would further simplify the threading model.

Issue Links

• relates to: FLINK-18832 BoundedBlockingSubpartition does not work with StreamTask
• links to: GitHub Pull Request #10939