fix not filtering out the primary key when collecting secondary keys

Signed-off-by: longfangsong <longfangsong@icloud.com>
This commit is contained in:
longfangsong 2020-12-18 17:14:41 +08:00
parent 161433f7aa
commit c556293cad
1 changed files with 6 additions and 1 deletions

View File

@ -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