commit 5f9fabc22e0741e62aa0c96c150709ccae74b9e8
author agresch <agresch@gmail.com> Fri Mar 05 10:14:51 2021 -0600
committer GitHub <noreply@github.com> Fri Mar 05 10:14:51 2021 -0600
tree ab7b1172a880aeb689269ad1ba5e5d1c37611f74
parent e3df2c17e758bf4fc02558f5976f7151ab2fe33a

STORM-3748 use ConcurrentHashMap for taskId metrics (#3383)

Co-authored-by: Aaron Gresch <agresch@yahoo-inc.com>

storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java

diff --git a/storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java b/storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java
index 3ea7a69..18177b9 100644
--- a/storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java
+++ b/storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java
@@ -198,7 +198,7 @@
 
     private static <T extends Metric> void saveMetricTaskIdMapping(Integer taskId, MetricNames names, T metric, Map<Integer,
             Map<String, T>> taskIdMetrics) {
-        Map<String, T> metrics = taskIdMetrics.computeIfAbsent(taskId, (tid) -> new HashMap<>());
+        Map<String, T> metrics = taskIdMetrics.computeIfAbsent(taskId, (tid) -> new ConcurrentHashMap<>());
         metrics.put(names.getShortName(), metric);
     }