From 1d209f9168a4eb6750bdad9ca1a69ac5755d70dc Mon Sep 17 00:00:00 2001
From: Aliaksandr Valialkin <valyala@victoriametrics.com>
Date: Sat, 11 May 2024 08:07:49 +0200
Subject: [PATCH] wip

---
 lib/logstorage/pipe_uniq.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/lib/logstorage/pipe_uniq.go b/lib/logstorage/pipe_uniq.go
index 95936fb52..6c171b931 100644
--- a/lib/logstorage/pipe_uniq.go
+++ b/lib/logstorage/pipe_uniq.go
@@ -121,9 +121,10 @@ func (shard *pipeUniqProcessorShard) writeBlock(br *blockResult) bool {
 	if len(byFields) == 0 {
 		// Take into account all the columns in br.
 		keyBuf := shard.keyBuf
+		cs := br.getColumns()
 		for i := range br.timestamps {
 			keyBuf = keyBuf[:0]
-			for _, c := range br.getColumns() {
+			for _, c := range cs {
 				v := c.getValueAtRow(br, i)
 				keyBuf = encoding.MarshalBytes(keyBuf, bytesutil.ToUnsafeBytes(c.name))
 				keyBuf = encoding.MarshalBytes(keyBuf, bytesutil.ToUnsafeBytes(v))