github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-03-11 15:34:56 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/storage: set bsm.Block to nil on error, so the previous block couldn't be used.

Browse source 
This may help nailing down the issue https://github.com/VictoriaMetrics/VictoriaMetrics/issues/2082
This commit is contained in:
Aliaksandr Valialkin 2022-01-20 20:11:56 +02:00
parent 5159a9451f
commit 54ee71e16d
No known key found for this signature in database
GPG key ID: A72BEC6CD3D0DED1
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/storage/block_stream_merger.go
View file

@ -88,12 +88,14 @@ func (bsm *blockStreamMerger) nextBlock() error {
} }
if err := bsrMin.Error(); err != nil { if err := bsrMin.Error(); err != nil {
bsm.Block = nil
return err return err
} }
heap.Pop(&bsm.bsrHeap) heap.Pop(&bsm.bsrHeap)
if len(bsm.bsrHeap) == 0 { if len(bsm.bsrHeap) == 0 {
bsm.Block = nil
return io.EOF return io.EOF
} }