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 <se...@apache.org> Authored: Wed May 25 18:39:16 2016 +0200 Committer: Stephan Ewen <se...@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) {
