fix(metrics): fix potential NPE when exporting metrics

Signed-off-by: Shichao Nie <niesc@automq.com>
AutoMQ · Sep 19, 2024 · d47c2f3 · d47c2f3
1 parent ac9b075
commit d47c2f3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/scala/kafka/log/stream/s3/telemetry/otel/OTelMetricsProcessor.java b/core/src/main/scala/kafka/log/stream/s3/telemetry/otel/OTelMetricsProcessor.java
@@ -75,8 +75,9 @@ private void processDeltaHistogramMetric(MetricName name, DeltaHistogram deltaHi
         metrics.compute(otelMetricName, (k, v) -> {
             if (v == null) {
                 v = new ConcurrentHashMap<>();
+                final Map<MetricName, MetricWrapper> finalV = v;
                 OTelMetricUtils.toMeanGaugeBuilder(meter, name).buildWithCallback(measurement ->
-                    metrics.get(otelMetricName).forEach((metricname, metricWrapper) ->
+                    finalV.forEach((metricname, metricWrapper) ->
                         measurement.record(metricWrapper.mean(), metricWrapper.getAttr())));
                 LOGGER.info("Created delta gauge for metric: {}", otelMetricName);
             }