From c0e86a51503e7f995f3e41c397e76f70acf4742f Mon Sep 17 00:00:00 2001 From: Tian Guangyu Date: Thu, 31 Dec 2015 12:23:09 +0800 Subject: [PATCH] add txn.Rollback on txn error --- kv/txn.go | 1 + 1 file changed, 1 insertion(+) diff --git a/kv/txn.go b/kv/txn.go index 197a6fc5c5..18515380bf 100644 --- a/kv/txn.go +++ b/kv/txn.go @@ -38,6 +38,7 @@ func RunInNewTxn(store Storage, retryable bool, f func(txn Transaction) error) e continue } if err != nil { + txn.Rollback() return errors.Trace(err) }