From 2bbe08ce8b660b9fd5907345857565b040844ebb Mon Sep 17 00:00:00 2001 From: Smita Kulkarni Date: Fri, 27 Jan 2023 22:37:42 +0100 Subject: [PATCH] Updated destructor to notify even when queue empty - Updated checking of SYSTEM SYNC REPLICA --- src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp b/src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp index 79e4afcdf7f..667bd725f44 100644 --- a/src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp +++ b/src/Storages/MergeTree/ReplicatedMergeTreeQueue.cpp @@ -2497,10 +2497,7 @@ void ReplicatedMergeTreeQueue::notifySubscribers(size_t new_queue_size, const St ReplicatedMergeTreeQueue::~ReplicatedMergeTreeQueue() { - if (!queue.empty()) - { - notifySubscribers(0, queue.back().get()->log_entry_id); - } + notifySubscribers(0, ""); } String padIndex(Int64 index)