From a7b849c5fa7190d09d0b6baf83269fdd7649a0df Mon Sep 17 00:00:00 2001 From: Souhaila Noor Date: Thu, 10 Mar 2022 16:18:39 -0600 Subject: [PATCH] release read tx --- holder.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/holder.go b/holder.go index 4d451c7ee..e40edc3dc 100644 --- a/holder.go +++ b/holder.go @@ -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)