This commit is contained in:
Aliaksandr Valialkin 2024-05-15 03:02:05 +02:00
parent edd493431e
commit fcce0fc6e1
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB

View file

@ -283,6 +283,7 @@ func (shard *pipeTopkProcessorShard) sortRows(stopCh <-chan struct{}) {
return
}
}
shard.rows = rows
}
func (ptp *pipeTopkProcessor) writeBlock(workerID uint, br *blockResult) {