clear reservoirs

newrelic · Nov 24, 2021 · 6d13914 · 6d13914
1 parent 5927fe8
commit 6d13914
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...rc/main/java/com/newrelic/agent/service/analytics/CollectorSpanEventReservoirManager.java b/...rc/main/java/com/newrelic/agent/service/analytics/CollectorSpanEventReservoirManager.java
@@ -52,7 +52,7 @@ private SamplingPriorityQueue<SpanEvent> createDistributedSamplingReservoir(Stri
 
     @Override
     public void clearReservoir() {
-        spanReservoirsForApp.forEach((appName, reservoir) -> reservoir.clear() );
+        spanReservoirsForApp.clear();
     }
 
     @Override

diff --git a/newrelic-agent/src/test/java/com/newrelic/agent/MockSpanEventReservoirManager.java b/newrelic-agent/src/test/java/com/newrelic/agent/MockSpanEventReservoirManager.java
@@ -50,7 +50,7 @@ private SamplingPriorityQueue<SpanEvent> createDistributedSamplingReservoir(Stri
 
     @Override
     public void clearReservoir() {
-        spanReservoirsForApp.forEach((appName, reservoir) -> reservoir.clear() );
+        spanReservoirsForApp.clear();
     }
 
     @Override