flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [1/3] flink git commit: [FLINK-3962] [core] Properly initialize I/O Metric Group
Date Thu, 26 May 2016 19:17:24 GMT
Repository: flink
Updated Branches:
  refs/heads/master ef5832d8f -> 573a92fc5


[FLINK-3962] [core] Properly initialize I/O Metric Group


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

Branch: refs/heads/master
Commit: 573a92fc5fe95aa7b07f5f7dc16c3d2a8efba16e
Parents: bf256c7
Author: Stephan Ewen <sewen@apache.org>
Authored: Wed May 25 18:39:16 2016 +0200
Committer: Stephan Ewen <sewen@apache.org>
Committed: Thu May 26 21:15:20 2016 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/metrics/groups/TaskMetricGroup.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/573a92fc/flink-core/src/main/java/org/apache/flink/metrics/groups/TaskMetricGroup.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/metrics/groups/TaskMetricGroup.java
b/flink-core/src/main/java/org/apache/flink/metrics/groups/TaskMetricGroup.java
index 3238534..316c84f 100644
--- a/flink-core/src/main/java/org/apache/flink/metrics/groups/TaskMetricGroup.java
+++ b/flink-core/src/main/java/org/apache/flink/metrics/groups/TaskMetricGroup.java
@@ -65,12 +65,13 @@ public class TaskMetricGroup extends ComponentMetricGroup {
 
 		this.executionId = executionId;
 		this.subtaskIndex = subtaskIndex;
-		this.ioMetrics = new IOMetricGroup(registry, this);
 		
 		this.formats.put(SCOPE_TASK_ID, taskId.toString());
 		this.formats.put(SCOPE_TASK_ATTEMPT, executionId.toString());
 		this.formats.put(SCOPE_TASK_NAME, checkNotNull(name));
 		this.formats.put(SCOPE_TASK_SUBTASK_INDEX, String.valueOf(subtaskIndex));
+
+		this.ioMetrics = new IOMetricGroup(registry, this);
 	}
 
 	public OperatorMetricGroup addOperator(String name) {


Mime
View raw message