[FLINK-4626] Missing break in MetricStore#add()

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.0
• Fix Version/s: 1.2.0
• Component/s: Runtime / Metrics
• Assignee: Chesnay Schepler
• Reporter: Ted Yu
• Created: 15/Sep/16 22:18
• Updated: 16/Sep/16 10:36
• Resolved: 16/Sep/16 10:36

Description

      switch (info.getCategory()) {
        case INFO_CATEGORY_JM:
          addMetric(jobManager.metrics, name, metric);
        case INFO_CATEGORY_TM:
          String tmID = ((QueryScopeInfo.TaskManagerQueryScopeInfo) info).taskManagerID;

Looks like a break is missing following addMetric(jobManager.metrics) call