From 39966457d9fb73ef23ebef2b14d34b66a6b87038 Mon Sep 17 00:00:00 2001
From: Smita Kulkarni <Smita.Kulkarni@clickhouse.com>
Date: Fri, 27 Jan 2023 13:36:44 +0100
Subject: [PATCH] Updated to remove waiting ids till the removed log entry -
 Updated checking of SYSTEM SYNC REPLICA

---
 src/Storages/StorageReplicatedMergeTree.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/Storages/StorageReplicatedMergeTree.cpp b/src/Storages/StorageReplicatedMergeTree.cpp
index 444b7d4f549..c4312b4a257 100644
--- a/src/Storages/StorageReplicatedMergeTree.cpp
+++ b/src/Storages/StorageReplicatedMergeTree.cpp
@@ -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);
                 }
             }