[STORM-254] one Spout/Bolt can register metric twice with same name

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.2-incubating
• Fix Version/s: 0.9.3
• Component/s: storm-core
• Assignee: DashengJu
• Reporter: DashengJu
• Created: 06/Mar/14 06:42
• Updated: 09/Oct/15 00:45
• Resolved: 21/Jul/14 16:24

Description

In a Bolt's prepare method, we can register metrics twice with the same name, using different timeBucketSizeInSecs parameter, like this:

public void prepare(Map stormConf, TopologyContext context)

{ mapper = new ObjectMapper(); cMetric = new MTCountMetric(); context.registerMetric("JavaBoltCount", cMetric, 120); ccMetric = new MTCountMetric(); context.registerMetric("JavaBoltCount", ccMetric, 60); }

----------------------------------------------------------------------------------------
This is caused by TopologyContext's registerMetric. In TopologyContext, all registered metrics holds in a map defined below:

private Map<Integer,Map<Integer, Map<String, IMetric>>> _registeredMetrics;

timeBucketSizeInSecs ----> __taskId ----> metricName ----> metirc