reset the records buffer when stop() is called.

Signed-off-by: gotjosh <josue.abreu@gmail.com>

pkg/storage/ingest/fetcher.go

@@ -304,6 +304,7 @@ func (r *concurrentFetchers) Stop() {
 	close(r.done)
 
 	r.wg.Wait()
+	r.bufferedFetchedRecords.Store(0)
 
 	level.Info(r.logger).Log("msg", "stopped concurrent fetchers", "last_returned_record", r.lastReturnedRecord)
 }