Kiu/VictoriaMetrics
Kiu/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-11-23 20:37:12 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

app/vmagent: properly flush big blocks of data

Browse Source 
Updates https://github.com/VictoriaMetrics/VictoriaMetrics/issues/741

Thanks to @IceRain00 for the investigation and initial attempt to fix the issue
at https://github.com/VictoriaMetrics/VictoriaMetrics/pull/742
This commit is contained in:
Aliaksandr Valialkin 2020-09-03 12:08:14 +03:00
parent 7a839b461f
commit ddabc13796
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/vmagent/remotewrite/pendingseries.go
View File

@ -126,9 +126,9 @@ func (wr *writeRequest) push(src []prompbmarshal.TimeSeries) {
tssDst := wr.tss tssDst := wr.tss
for i := range src { for i := range src {
tssDst = append(tssDst, prompbmarshal.TimeSeries{}) tssDst = append(tssDst, prompbmarshal.TimeSeries{})
dst := &tssDst[len(tssDst)-1] wr.copyTimeSeries(&tssDst[len(tssDst)-1], &src[i])
wr.copyTimeSeries(dst, &src[i]) if len(tssDst) >= maxRowsPerBlock {
if len(wr.tss) >= maxRowsPerBlock { wr.tss = tssDst
wr.flush() wr.flush()
tssDst = wr.tss tssDst = wr.tss
} }