From 2b6238a5e548226275fefece93684296fca2b5f5 Mon Sep 17 00:00:00 2001
From: Michael Stetsyuk <michael.stetsyuk@clickhouse.com>
Date: Fri, 13 Sep 2024 13:41:01 +0000
Subject: [PATCH 1/2] sleep for 10ms beforen retrying to acquire a lock in
 DatabaseReplicatedDDLWorker::enqueueQueryImpl

---
 src/Databases/DatabaseReplicatedWorker.cpp | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/Databases/DatabaseReplicatedWorker.cpp b/src/Databases/DatabaseReplicatedWorker.cpp
index 4e7408aa96e..07150957912 100644
--- a/src/Databases/DatabaseReplicatedWorker.cpp
+++ b/src/Databases/DatabaseReplicatedWorker.cpp
@@ -4,6 +4,7 @@
 #include <Common/ZooKeeper/KeeperException.h>
 #include <Core/ServerUUID.h>
 #include <Core/Settings.h>
+#include <chrono>
 #include <filesystem>
 
 namespace fs = std::filesystem;
@@ -249,6 +250,8 @@ String DatabaseReplicatedDDLWorker::enqueueQueryImpl(const ZooKeeperPtr & zookee
         }
         else if (code != Coordination::Error::ZNODEEXISTS)
             zkutil::KeeperMultiException::check(code, ops, res);
+
+        std::this_thread::sleep_for(std::chrono::milliseconds(50));
     }
 
     if (counter_path.empty())

From 4225ba79f9307cfee9a367966049185e4c722c89 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mi=D1=81hael=20Stetsyuk?=
 <59827607+mstetsyuk@users.noreply.github.com>
Date: Fri, 13 Sep 2024 17:35:11 +0100
Subject: [PATCH 2/2] use base/sleep.h

---
 src/Databases/DatabaseReplicatedWorker.cpp | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Databases/DatabaseReplicatedWorker.cpp b/src/Databases/DatabaseReplicatedWorker.cpp
index 07150957912..7993a41df53 100644
--- a/src/Databases/DatabaseReplicatedWorker.cpp
+++ b/src/Databases/DatabaseReplicatedWorker.cpp
@@ -4,7 +4,7 @@
 #include <Common/ZooKeeper/KeeperException.h>
 #include <Core/ServerUUID.h>
 #include <Core/Settings.h>
-#include <chrono>
+#include <base/sleep.h>
 #include <filesystem>
 
 namespace fs = std::filesystem;
@@ -251,7 +251,7 @@ String DatabaseReplicatedDDLWorker::enqueueQueryImpl(const ZooKeeperPtr & zookee
         else if (code != Coordination::Error::ZNODEEXISTS)
             zkutil::KeeperMultiException::check(code, ops, res);
 
-        std::this_thread::sleep_for(std::chrono::milliseconds(50));
+        sleepForMilliseconds(50);
     }
 
     if (counter_path.empty())