[FLINK-7456] Implement Netty sender incoming pipeline for credit-based

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Component/s: Runtime / Network
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 16/Aug/17 10:20
• Updated: 20/Feb/18 10:17
• Resolved: 20/Feb/18 10:17

Description

This is a part of work for credit-based network flow control.

On sender side, each subpartition view maintains an atomic integer currentCredit from receiver. Once receiving the messages of PartitionRequest and AddCredit, the currentCredit is added by deltas.

Each view also maintains an atomic boolean field to mark it as registered available for transfer to make sure it is enqueued in handler only once. If the currentCredit increases from zero and there are available buffers in the subpartition, the corresponding view will be enqueued for transferring data.

Issue Links

• links to: GitHub Pull Request #4552