Merge 4225ba79f9 into 733c57dae7

use base/sleep.h
sleep for 10ms beforen retrying to acquire a lock in DatabaseReplicatedDDLWorker::enqueueQueryImpl
2024-09-19 16:20:50 +00:00 · 2024-09-16 00:30:50 +02:00 · 2024-09-13 17:35:11 +01:00 · 2024-09-13 13:41:01 +00:00
1 changed files with 3 additions and 0 deletions
--- 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 <base/sleep.h>
 #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);
+
+        sleepForMilliseconds(50);
    }

    if (counter_path.empty())
Author	SHA1	Message	Date
Miсhael Stetsyuk	f76693cafe	Merge `4225ba79f9` into `733c57dae7`	2024-09-16 00:30:50 +02:00
Miсhael Stetsyuk	4225ba79f9	use base/sleep.h	2024-09-13 17:35:11 +01:00
Michael Stetsyuk	2b6238a5e5	sleep for 10ms beforen retrying to acquire a lock in DatabaseReplicatedDDLWorker::enqueueQueryImpl	2024-09-13 13:41:01 +00:00