diff --git a/mvcc/backend/backend.go b/mvcc/backend/backend.go index 4698c087d..11a1c46c7 100644 --- a/mvcc/backend/backend.go +++ b/mvcc/backend/backend.go @@ -399,14 +399,7 @@ func (b *backend) defrag() error { plog.Panicf("cannot open database at %s (%v)", dbp, err) } } - b.batchTx.tx, err = b.db.Begin(true) - if err != nil { - if b.lg != nil { - b.lg.Fatal("failed to begin tx", zap.Error(err)) - } else { - plog.Fatalf("cannot begin tx (%s)", err) - } - } + b.batchTx.tx = b.unsafeBegin(true) b.readTx.reset() b.readTx.tx = b.unsafeBegin(false)