diff --git a/dbms/src/Interpreters/DDLWorker.cpp b/dbms/src/Interpreters/DDLWorker.cpp index 861a6b5ff03ca24fb7eca4aae1a68a000d2b4a29..3077290e3feaa3fbc859d7c266e5aec867b8312b 100644 --- a/dbms/src/Interpreters/DDLWorker.cpp +++ b/dbms/src/Interpreters/DDLWorker.cpp @@ -941,22 +941,19 @@ void DDLWorker::runMainThread() { try { - try - { - auto zookeeper = getAndSetZooKeeper(); - zookeeper->createAncestors(queue_dir + "/"); - initialized = true; - } - catch (const Coordination::Exception & e) - { - if (!Coordination::isHardwareError(e.code)) - throw; /// A logical error. + auto zookeeper = getAndSetZooKeeper(); + zookeeper->createAncestors(queue_dir + "/"); + initialized = true; + } + catch (const Coordination::Exception & e) + { + if (!Coordination::isHardwareError(e.code)) + throw; /// A logical error. - tryLogCurrentException(__PRETTY_FUNCTION__); + tryLogCurrentException(__PRETTY_FUNCTION__); - /// Avoid busy loop when ZooKeeper is not available. - sleepForSeconds(1); - } + /// Avoid busy loop when ZooKeeper is not available. + sleepForSeconds(1); } catch (...) {