From c556293cad9e359ba75282ea6681eca61114b3be Mon Sep 17 00:00:00 2001 From: longfangsong Date: Fri, 18 Dec 2020 17:14:41 +0800 Subject: [PATCH] fix not filtering out the primary key when collecting secondary keys Signed-off-by: longfangsong --- src/transaction/transaction.rs | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/transaction/transaction.rs b/src/transaction/transaction.rs index 20e4c82..2da3280 100644 --- a/src/transaction/transaction.rs +++ b/src/transaction/transaction.rs @@ -714,7 +714,12 @@ impl Committer { request.use_async_commit = self.options.async_commit; request.try_one_pc = self.options.try_one_pc; - request.secondaries = self.mutations[1..].iter().map(|m| m.key.clone()).collect(); + request.secondaries = self + .mutations + .iter() + .filter(|m| self.primary_key.as_ref().unwrap() != m.key.as_ref()) + .map(|m| m.key.clone()) + .collect(); // FIXME set max_commit_ts and min_commit_ts let response = request