diff --git a/app/vmselect/prometheus/prometheus.go b/app/vmselect/prometheus/prometheus.go index db1f89e764..f5eebc0353 100644 --- a/app/vmselect/prometheus/prometheus.go +++ b/app/vmselect/prometheus/prometheus.go @@ -180,8 +180,10 @@ func ExportCSVHandler(startTime time.Time, w http.ResponseWriter, r *http.Reques close(resultsCh) doneCh <- err }() + // Consume all the data from resultsCh. for bb := range resultsCh { - bw.Write(bb.B) + // Do not check for error in bw.Write, since this error is checked inside netstorage.ExportBlocks above. + _, _ = bw.Write(bb.B) quicktemplate.ReleaseByteBuffer(bb) } if err := bw.Flush(); err != nil {