[FLINK-14472] Implement back-pressure monitor with non-blocking outputs

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.10.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Yingjie Cao
• Reporter: Zhijiang
• Created: 21/Oct/19 07:27
• Updated: 14/Nov/19 16:30
• Resolved: 14/Nov/19 16:30

Description

Currently back-pressure monitor relies on detecting task threads that are stuck in `requestBufferBuilderBlocking`. There are actually two cases to cause back-pressure ATM:

• There are no available buffers in `LocalBufferPool` and all the given quotas from global pool are also exhausted. Then we need to wait for buffer recycling to `LocalBufferPool`.
• No available buffers in `LocalBufferPool`, but the quota has not been used up. While requesting buffer from global pool, it is blocked because of no available buffers in global pool. Then we need to wait for buffer recycling to global pool.

We try to implement the non-blocking network output in FLINK-14396, so the back pressure monitor should be adjusted accordingly after the non-blocking output is used in practice.

In detail we try to avoid the current monitor way by analyzing the task thread stack, which has some drawbacks discussed before:

• If the `requestBuffer` is not triggered by task thread, the current monitor is invalid in practice.
• The current monitor is heavy-weight and fragile because it needs to understand more details of LocalBufferPool implementation.  

We could provide a transparent method for the monitor caller to get the backpressure result directly, and hide the implementation details in the LocalBufferPool.

Issue Links

• blocks: FLINK-14553 Respect non-blocking output in StreamTask#processInput
• relates to: FLINK-14712 Improve back-pressure reporting mechanism
• links to: GitHub Pull Request #10083