Skip to content

Commit 3f91f32

Browse files
authored
Merge pull request #273 from ekexium/1pc-panic
Fix 1PC panic
2 parents 0535be6 + 77fbe89 commit 3f91f32

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/transaction/requests.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -240,7 +240,7 @@ impl Shardable for kvrpcpb::PrewriteRequest {
240240
}
241241

242242
// Only if there is only one request to send
243-
if self.try_one_pc && self.mutations.len() != self.secondaries.len() + 1 {
243+
if self.try_one_pc && shard.len() != self.secondaries.len() + 1 {
244244
self.set_try_one_pc(false);
245245
}
246246

0 commit comments

Comments
 (0)