thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

DDLWorkerQueueTable - load distributed_ddl.path from server config

Browse Source
This commit is contained in:
bharatnc 2020-12-05 16:24:18 -08:00
parent b008c49bd9
commit cc568a1d2c
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Storages/System/StorageSystemDDLWorkerQueue.cpp
View File

@ -7,7 +7,6 @@
#include <DataTypes/DataTypeArray.h>
#include <DataTypes/DataTypeString.h>
#include <Interpreters/Context.h>
#include <Poco/Util/Application.h>
#include <Common/ZooKeeper/ZooKeeper.h>
@ -27,9 +26,7 @@ void StorageSystemDDLWorkerQueue::fillData(MutableColumns & res_columns, const C
{
zkutil::ZooKeeperPtr zookeeper = context.getZooKeeper();
// TODO: load using config().getString("distributed_ddl.path", "/clickhouse/task_queue/ddl/");
String ddl_zookeeper_path = "/clickhouse/task_queue/ddl";
String ddl_zookeeper_path = config.getString("distributed_ddl.path", "/clickhouse/task_queue/ddl/");
String ddl_query_path;
// this is equivalent to query zookeeper at the `ddl_zookeeper_path`

4
src/Storages/System/StorageSystemDDLWorkerQueue.h
View File

@ -1,5 +1,8 @@
#pragma once
#include <Poco/Util/Application.h>
#include <Poco/Util/LayeredConfiguration.h>
#include <Storages/System/IStorageSystemOneBlock.h>
#include <ext/shared_ptr_helper.h>
@ -15,6 +18,7 @@ class StorageSystemDDLWorkerQueue final : public ext::shared_ptr_helper<StorageS
public IStorageSystemOneBlock<StorageSystemDDLWorkerQueue>
{
friend struct ext::shared_ptr_helper<StorageSystemDDLWorkerQueue>;
Poco::Util::LayeredConfiguration & config = Poco::Util::Application::instance().config();
protected:
void fillData(MutableColumns & res_columns, const Context & context, const SelectQueryInfo & query_info) const override;