Compare commits

...

3 Commits

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

View File

@ -4,6 +4,7 @@
#include <Common/ZooKeeper/KeeperException.h> #include <Common/ZooKeeper/KeeperException.h>
#include <Core/ServerUUID.h> #include <Core/ServerUUID.h>
#include <Core/Settings.h> #include <Core/Settings.h>
#include <base/sleep.h>
#include <filesystem> #include <filesystem>
namespace fs = std::filesystem; namespace fs = std::filesystem;
@ -249,6 +250,8 @@ String DatabaseReplicatedDDLWorker::enqueueQueryImpl(const ZooKeeperPtr & zookee
} }
else if (code != Coordination::Error::ZNODEEXISTS) else if (code != Coordination::Error::ZNODEEXISTS)
zkutil::KeeperMultiException::check(code, ops, res); zkutil::KeeperMultiException::check(code, ops, res);
sleepForMilliseconds(50);
} }
if (counter_path.empty()) if (counter_path.empty())