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

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-15 12:15:16 +02:00
parent 87de9936f9
commit 21f09ab823
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
2 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
docs/VictoriaLogs/CHANGELOG.md
View file

@ -19,6 +19,8 @@ according to [these docs](https://docs.victoriametrics.com/VictoriaLogs/QuickSta
## tip ## tip
* BUGFIX: properly take into account `offset` [`sort` pipe](https://docs.victoriametrics.com/victorialogs/logsql/#sort-pipe) when it already has `limit`. For example, `_time:5m | sort by (foo) offset 20 limit 10`.
## [v0.7.0](https://github.com/VictoriaMetrics/VictoriaMetrics/releases/tag/v0.7.0-victorialogs) ## [v0.7.0](https://github.com/VictoriaMetrics/VictoriaMetrics/releases/tag/v0.7.0-victorialogs)
Released at 2024-05-15 Released at 2024-05-15

2
lib/logstorage/pipe_topk.go
View file

@ -263,7 +263,7 @@ func (shard *pipeTopkProcessorShard) addRow(byColumns []string, otherColumns []F
// Slow path - add r to shard.rows. // Slow path - add r to shard.rows.
r = r.clone() r = r.clone()
shard.stateSizeBudget -= r.sizeBytes() shard.stateSizeBudget -= r.sizeBytes()
if uint64(len(rows)) < shard.ps.limit { if uint64(len(rows)) < shard.ps.offset+shard.ps.limit {
heap.Push(shard, r) heap.Push(shard, r)
shard.stateSizeBudget -= int(unsafe.Sizeof(r)) shard.stateSizeBudget -= int(unsafe.Sizeof(r))
} else { } else {