Ted Yu created FLINK-4626: ----------------------------- Summary: Missing break in MetricStore#add() Key: FLINK-4626 URL: https://issues.apache.org/jira/browse/FLINK-4626 Project: Flink Issue Type: Bug Reporter: Ted Yu
{code} switch (info.getCategory()) { case INFO_CATEGORY_JM: addMetric(jobManager.metrics, name, metric); case INFO_CATEGORY_TM: String tmID = ((QueryScopeInfo.TaskManagerQueryScopeInfo) info).taskManagerID; {code} Looks like a break is missing following addMetric(jobManager.metrics) call -- This message was sent by Atlassian JIRA (v6.3.4#6332)