This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 928d656 [hotfix] fix a typo in KafkaTestBase
add dea617c [FLINK-25590][metrics] Introduce RequestedMemoryUsage and log
warnings if usage exceeds 100%
add cfe5e9a fixup! [FLINK-25590][metrics] Introduce RequestedMemoryUsage
and log warnings if usage exceeds 100%
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/ops/metrics.md | 9 ++-
docs/content/docs/ops/metrics.md | 9 ++-
.../runtime/io/network/buffer/LocalBufferPool.java | 13 ++++
.../io/network/buffer/NetworkBufferPool.java | 65 ++++++++++++++++++++
.../network/metrics/NettyShuffleMetricFactory.java | 29 +++++++++
.../flink/runtime/shuffle/NettyShuffleUtils.java | 3 +-
.../io/network/buffer/NetworkBufferPoolTest.java | 69 ++++++++++++++++++++++
7 files changed, 192 insertions(+), 5 deletions(-)
