You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by pn...@apache.org on 2019/11/28 14:34:26 UTC

[flink] branch master updated (2ac0dd0 -> 2772cd0)

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 2ac0dd0  [FLINK-14709] Dispose resources in ChainedDriver close method instead of closeTask.
     add 2772cd0  [FLINK-14813][metrics] Provide `isBackPressured` Task metric

No new revisions were added by this update.

Summary of changes:
 docs/monitoring/metrics.md                         | 26 ++++++++++++++++++++--
 docs/monitoring/metrics.zh.md                      | 25 +++++++++++++++++++--
 .../io/network/NettyShuffleEnvironment.java        | 11 ++++++++-
 .../io/network/metrics/BackPressureGauge.java      | 17 +++++++-------
 .../network/metrics/NettyShuffleMetricFactory.java | 15 +++++++++++++
 .../flink/runtime/shuffle/ShuffleEnvironment.java  |  8 +++++++
 .../runtime/shuffle/ShuffleIOOwnerContext.java     |  9 +++++++-
 .../org/apache/flink/runtime/taskmanager/Task.java |  1 +
 .../TaskExecutorPartitionLifecycleTest.java        |  6 +++++
 .../apache/flink/runtime/taskmanager/TaskTest.java |  8 +++++++
 10 files changed, 112 insertions(+), 14 deletions(-)
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/metrics/WatermarkGauge.java => flink-runtime/src/main/java/org/apache/flink/runtime/io/network/metrics/BackPressureGauge.java (69%)