Skip to content

Commit 9030efb

Browse files
authored
[connector/signaltometrics] Cleanup sums cache after finalize (#184)
1 parent 8411df2 commit 9030efb

File tree

1 file changed

+1
-0
lines changed
  • connector/signaltometricsconnector/internal/aggregator

1 file changed

+1
-0
lines changed

connector/signaltometricsconnector/internal/aggregator/aggregator.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,7 @@ func (a *Aggregator[K]) Finalize(mds []model.MetricDef[K]) {
162162
// then they will be aggregated within the same metric and produced
163163
// together. Deleting the key ensures this while preventing duplicates.
164164
delete(a.valueCounts, md.Key)
165+
delete(a.sums, md.Key)
165166
}
166167
}
167168

0 commit comments

Comments
 (0)