build a new batch while starting to process a bucket (#5580)

pull/5585/head
Sandeep Sukhani 3 years ago committed by GitHub
parent dee6a56df1
commit c76544baf9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 3
      pkg/storage/stores/shipper/compactor/table.go

@ -430,10 +430,9 @@ func readFile(logger log.Logger, path string, writeBatch func(userID string, bat
}
}()
batch := make([]indexEntry, 0, batchSize)
return db.View(func(tx *bbolt.Tx) error {
return tx.ForEach(func(name []byte, b *bbolt.Bucket) error {
batch := make([]indexEntry, 0, batchSize)
bucketNameStr := string(name)
err := b.ForEach(func(k, v []byte) error {
ie := indexEntry{

Loading…
Cancel
Save