提交 ff1cb65f 编写于 作者: A Azat Khuzhin

Start accepting connections after DDLWorker and dictionaries initialization

Found by integration tests [1]:

    Code: 139. DB::Exception: Received from 172.18.0.6:9000. DB::Exception: DDL background thread is not initialized. Stack trace:

  [1]: https://clickhouse-test-reports.s3.yandex.net/21643/65f90f2ce9ea9e9d4076f06c58ddd981c82cc098/integration_tests_(thread).html#fail1
上级 f6bedf55
...@@ -1280,9 +1280,6 @@ int Server::main(const std::vector<std::string> & /*args*/) ...@@ -1280,9 +1280,6 @@ int Server::main(const std::vector<std::string> & /*args*/)
async_metrics.start(); async_metrics.start();
global_context->enableNamedSessions(); global_context->enableNamedSessions();
for (auto & server : *servers)
server.start();
{ {
String level_str = config().getString("text_log.level", ""); String level_str = config().getString("text_log.level", "");
int level = level_str.empty() ? INT_MAX : Poco::Logger::parseLevel(level_str); int level = level_str.empty() ? INT_MAX : Poco::Logger::parseLevel(level_str);
...@@ -1334,6 +1331,8 @@ int Server::main(const std::vector<std::string> & /*args*/) ...@@ -1334,6 +1331,8 @@ int Server::main(const std::vector<std::string> & /*args*/)
"distributed_ddl", "DDLWorker", &CurrentMetrics::MaxDDLEntryID)); "distributed_ddl", "DDLWorker", &CurrentMetrics::MaxDDLEntryID));
} }
for (auto & server : *servers)
server.start();
LOG_INFO(log, "Ready for connections."); LOG_INFO(log, "Ready for connections.");
SCOPE_EXIT({ SCOPE_EXIT({
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册