[FLINK-19130] Expose backpressure metrics / logs for function dispatcher operator

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Component/s: Stateful Functions
• Labels: pull-request-available stale-assigned
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 03/Sep/20 04:50
• Updated: 27/Apr/21 18:07
• Resolved: 21/Apr/21 08:03

Description

As of now, there is no visibility on why or how backpressure is applied in Stateful Functions.
This JIRA attemps to add two metrics as an initial effort of providing more visibility:

• Total number of addresses that have asked to be blocked
• Total number of inflight pending async operations

Issue Links

• links to: GitHub Pull Request #142