diff --git a/mvcc/backend/backend.go b/mvcc/backend/backend.go index 1fcceb68b..9a96bee2a 100644 --- a/mvcc/backend/backend.go +++ b/mvcc/backend/backend.go @@ -464,6 +464,11 @@ func defragdb(odb, tmpdb *bolt.DB, limit int) error { if err != nil { return err } + defer func() { + if err != nil { + tmptx.Rollback() + } + }() // open a tx on old db for read tx, err := odb.Begin(false)