| commit | 78cbc19bddfb6da38a00a9fce5ec7c011ecb3c72 | [log] [tgz] |
|---|---|---|
| author | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Fri Sep 04 11:43:59 2020 +0800 |
| committer | Tzu-Li (Gordon) Tai <tzulitai@apache.org> | Fri Sep 04 13:23:24 2020 +0800 |
| tree | 088a4229f7b2f8dcbcc6fa68c51759842b5aa103 | |
| parent | 09b4d4ff33756c8ad3380713ce07c336aa981bcd [diff] |
[FLINK-19130] [core] Extend metric interfaces for backpressure metrics This commit extends the FunctionTypeMetrics interface and introduces a new FunctionDispatcherMetrics interface with a goal to expose the following backpressure-related metrics: - Number of blocked addresses (per function type) - Number of inflight async ops (per function type + per-operator)