thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-02 20:42:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Updated to remove waiting ids till the removed log entry - Updated checking of SYSTEM SYNC REPLICA

Browse Source
This commit is contained in:
Smita Kulkarni 2023-01-27 13:36:44 +01:00
parent a95609e0bc
commit 39966457d9
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Storages/StorageReplicatedMergeTree.cpp
View File

@ -7553,7 +7553,8 @@ bool StorageReplicatedMergeTree::waitForProcessingQueue(UInt64 max_wait_millisec
}
else
{
wait_for_ids.erase(wait_for_ids.begin(),iterator);
/// Remove items till the removed_log_entry_id (including it)
wait_for_ids.erase(wait_for_ids.begin(),iterator + 1);
}
}