From fcce0fc6e1c8af84e3e14e59c75f979bce421859 Mon Sep 17 00:00:00 2001
From: Aliaksandr Valialkin <valyala@victoriametrics.com>
Date: Wed, 15 May 2024 03:02:05 +0200
Subject: [PATCH] wip

---
 lib/logstorage/pipe_topk.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/lib/logstorage/pipe_topk.go b/lib/logstorage/pipe_topk.go
index d90efa94e..1b2018c4e 100644
--- a/lib/logstorage/pipe_topk.go
+++ b/lib/logstorage/pipe_topk.go
@@ -283,6 +283,7 @@ func (shard *pipeTopkProcessorShard) sortRows(stopCh <-chan struct{}) {
 			return
 		}
 	}
+	shard.rows = rows
 }
 
 func (ptp *pipeTopkProcessor) writeBlock(workerID uint, br *blockResult) {