Repository: flink Updated Branches: refs/heads/master 7143a2454 -> db90580ff
[FLINK-4626] Add missing break in MEtricStore#add() Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1586fc8c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1586fc8c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1586fc8c Branch: refs/heads/master Commit: 1586fc8cfc6f41244e46b27ad25dcb6b08b7ce43 Parents: 7143a24 Author: zentol <[email protected]> Authored: Fri Sep 16 12:31:55 2016 +0200 Committer: zentol <[email protected]> Committed: Fri Sep 16 12:31:55 2016 +0200 ---------------------------------------------------------------------- .../org/apache/flink/runtime/webmonitor/metrics/MetricStore.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/1586fc8c/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java ---------------------------------------------------------------------- diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java index 41e68cc..5df63c6 100644 --- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java +++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java @@ -65,6 +65,7 @@ public class MetricStore { switch (info.getCategory()) { case INFO_CATEGORY_JM: addMetric(jobManager.metrics, name, metric); + break; case INFO_CATEGORY_TM: String tmID = ((QueryScopeInfo.TaskManagerQueryScopeInfo) info).taskManagerID; tm = taskManagers.get(tmID);
