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

Updated destructor to notify even when queue empty - Updated checking of SYSTEM SYNC REPLICA

Browse Source
This commit is contained in:
Smita Kulkarni 2023-01-27 22:37:42 +01:00
parent b22fd40d92
commit 2bbe08ce8b
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp
View File

@ -2497,10 +2497,7 @@ void ReplicatedMergeTreeQueue::notifySubscribers(size_t new_queue_size, const St
ReplicatedMergeTreeQueue::~ReplicatedMergeTreeQueue() ReplicatedMergeTreeQueue::~ReplicatedMergeTreeQueue()
{ {
if (!queue.empty()) notifySubscribers(0, "");
{
notifySubscribers(0, queue.back().get()->log_entry_id);
}
} }
String padIndex(Int64 index) String padIndex(Int64 index)