scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-08 11:57:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

release read tx

Browse source
This commit is contained in:
Souhaila Noor 2022-03-10 16:18:39 -06:00
parent c67b8f6653
commit a7b849c5fa
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
holder.go
View file

@ -318,6 +318,8 @@ func (h *Holder) deletePerShard(index *Index, shard uint64) error {
}
h.Logger.Printf("retrying delete: index=%v shard=%v record count=%v", index.name, shard, inprocessRecords.Count())
tx.Rollback() // release the read tx in case a checksum is needed in DeleteRows
_, err = DeleteRows(context.Background(), inprocessRecords, index, shard)
if err != nil {
return fmt.Errorf("deleting rows: %v", err)