thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix snapshot sync

Browse Source
This commit is contained in:
Antonio Andelic 2024-09-07 17:34:59 +02:00
parent 5a86371b02
commit 190339c4e6
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/Coordination/KeeperStorage.cpp
View File

@ -2609,8 +2609,15 @@ void KeeperStorage<Container>::preprocessRequest(
else
{
if (last_zxid == new_last_zxid && digest && checkDigest(*digest, current_digest))
// we found the preprocessed request with the same ZXID, we can skip it
{
auto & last_transaction = uncommitted_transactions.back();
// we found the preprocessed request with the same ZXID, we can get log_idx and skip preprocessing it
chassert(last_transaction.zxid == new_last_zxid && log_idx != 0);
/// initially leader preprocessed without knowing the log idx
/// on the second call we have that information and can set the log idx for the correct transaction
last_transaction.log_idx = log_idx;
return;
}
if (new_last_zxid <= last_zxid)
throw Exception(