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-11 08:07:49 +02:00
parent a55e01e406
commit 1d209f9168
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/logstorage/pipe_uniq.go
View file

@ -121,9 +121,10 @@ func (shard *pipeUniqProcessorShard) writeBlock(br *blockResult) bool {
if len(byFields) == 0 { if len(byFields) == 0 {
// Take into account all the columns in br. // Take into account all the columns in br.
keyBuf := shard.keyBuf keyBuf := shard.keyBuf
cs := br.getColumns()
for i := range br.timestamps { for i := range br.timestamps {
keyBuf = keyBuf[:0] keyBuf = keyBuf[:0]
for _, c := range br.getColumns() { for _, c := range cs {
v := c.getValueAtRow(br, i) v := c.getValueAtRow(br, i)
keyBuf = encoding.MarshalBytes(keyBuf, bytesutil.ToUnsafeBytes(c.name)) keyBuf = encoding.MarshalBytes(keyBuf, bytesutil.ToUnsafeBytes(c.name))
keyBuf = encoding.MarshalBytes(keyBuf, bytesutil.ToUnsafeBytes(v)) keyBuf = encoding.MarshalBytes(keyBuf, bytesutil.ToUnsafeBytes(v))