You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/01/31 13:28:11 UTC

flink git commit: [FLINK-8496][metrics] Create missing "Network" group

Repository: flink
Updated Branches:
  refs/heads/release-1.4 14aabf82c -> 0cc0572c4


[FLINK-8496][metrics] Create missing "Network" group

This closes #5343.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0cc0572c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0cc0572c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0cc0572c

Branch: refs/heads/release-1.4
Commit: 0cc0572c441ac1653edbd3a1e9acb3e07af461c2
Parents: 14aabf8
Author: zentol <ch...@apache.org>
Authored: Tue Jan 23 17:32:44 2018 +0100
Committer: zentol <ch...@apache.org>
Committed: Wed Jan 31 14:27:57 2018 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/runtime/metrics/util/MetricUtils.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/0cc0572c/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java
index 2a59a7f..3fd268a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/metrics/util/MetricUtils.java
@@ -83,7 +83,10 @@ public class MetricUtils {
 
 		// Initialize the TM metrics
 		instantiateStatusMetrics(statusGroup);
-		instantiateNetworkMetrics(statusGroup, network);
+
+		MetricGroup networkGroup = statusGroup
+			.addGroup("Network");
+		instantiateNetworkMetrics(networkGroup, network);
 
 		return taskManagerMetricGroup;
 	}