clear

fandreuz · fandreuz · commit d747d660af38 · 2025-05-22T02:42:08.000+02:00
diff --git a/sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/DefaultSynchronousMetricStorage.java b/sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/state/DefaultSynchronousMetricStorage.java
@@ -137,6 +137,7 @@ public void setEnabled(boolean enabled) {
       AggregatorHolder<T, U> localAggregatorHolder = Objects.requireNonNull(aggregatorHolder.get());
       if (localAggregatorHolder.aggregator == Aggregator.drop()) {
         AggregatorHolder<T, U> newHolder = new AggregatorHolder<>(originalAggregator);
+        previousCollectionAggregatorHandles.clear();
         // If this fails, another thread called `setEnabled` and we can discard the current call
         aggregatorHolder.compareAndSet(localAggregatorHolder, newHolder);
       }

Original file line number	Diff line number	Diff line change
`@@ -137,6 +137,7 @@ public void setEnabled(boolean enabled) {`
`137`	`137`	`AggregatorHolder<T, U> localAggregatorHolder = Objects.requireNonNull(aggregatorHolder.get());`
`138`	`138`	`if (localAggregatorHolder.aggregator == Aggregator.drop()) {`
`139`	`139`	`AggregatorHolder<T, U> newHolder = new AggregatorHolder<>(originalAggregator);`
	`140`	`+ previousCollectionAggregatorHandles.clear();`
`140`	`141`	// If this fails, another thread called `setEnabled` and we can discard the current call
`141`	`142`	`aggregatorHolder.compareAndSet(localAggregatorHolder, newHolder);`
`142`	`143`	`}`