[FLINK-4626] Add missing break in MEtricStore#add()

ivanliu · Sep 16, 2016 · 1586fc8 · 1586fc8
1 parent 7143a24
commit 1586fc8
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -65,6 +65,7 @@ public void add(MetricDump metric) {
 			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);