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 <ches...@apache.org>
Authored: Fri Sep 16 12:31:55 2016 +0200
Committer: zentol <ches...@apache.org>
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);

Reply via email to