From 50b83900475d92469b589fa29d7939fb4e3790dd Mon Sep 17 00:00:00 2001 From: disksing Date: Wed, 10 Jul 2019 18:49:25 +0800 Subject: [PATCH] txnkv: fix commit bug Signed-off-by: disksing --- txnkv/txn.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/txnkv/txn.go b/txnkv/txn.go index 837661ae14..b6d851a05f 100644 --- a/txnkv/txn.go +++ b/txnkv/txn.go @@ -204,6 +204,9 @@ func (txn *Transaction) Commit(ctx context.Context) error { if c := txn.us.LookupConditionPair(k); c != nil && c.ShouldNotExist() { op = kvrpcpb.Op_Insert } + if len(v) == 0 { + op = kvrpcpb.Op_Del + } mutations[string(k)] = &kvrpcpb.Mutation{ Op: op, Key: k,