[STORM-3623] v2 metrics tick reports all worker metrics within each executor

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0, 2.1.0
• Fix Version/s: 2.2.0
• Labels: pull-request-available
• Assignee: Aaron Gresch
• Reporter: Ethan Li
• Created: 15/Apr/20 14:12
• Updated: 01/Jul/20 14:07
• Resolved: 28/Apr/20 18:47

Description

see https://github.com/apache/storm/blob/master/storm-client/src/jvm/org/apache/storm/executor/Executor.java#L335-L341

    private void addV2Metrics(List<IMetricsConsumer.DataPoint> dataPoints) {
        boolean enableV2MetricsDataPoints = ObjectReader.getBoolean(topoConf.get(Config.TOPOLOGY_ENABLE_V2_METRICS_TICK), false);
        if (!enableV2MetricsDataPoints) {
            return;
        }
        StormMetricRegistry stormMetricRegistry = workerData.getMetricRegistry();

This should be reporting just the metrics for the Executor.

Issue Links

• is related to: STORM-3622 Race Condition in CachedThreadStatesGaugeSet registered at SystemBolt
• links to: GitHub Pull Request #3251