github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-01-10 15:14:09 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/streamaggr: limit the the number of concurrent flushes of the aggregate data to the exact number of available CPUs

Browse source 
This should reduce the maximum memory usage during concurrent flushes of the aggregate data
This commit is contained in:
Aliaksandr Valialkin 2023-01-07 00:18:49 -08:00
parent ad5bfe3089
commit 5fe7ff24c2
No known key found for this signature in database
GPG key ID: A72BEC6CD3D0DED1
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/streamaggr/streamaggr.go
View file

@ -356,7 +356,7 @@ func (a *aggregator) runFlusher(interval time.Duration) {
}
}
var flushConcurrencyCh = make(chan struct{}, 2*cgroup.AvailableCPUs())
var flushConcurrencyCh = make(chan struct{}, cgroup.AvailableCPUs())
func (a *aggregator) flush() {
ctx := &flushCtx{