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) {