diff --git a/dbms/src/Common/ZooKeeper/Types.h b/dbms/src/Common/ZooKeeper/Types.h index ba94606c8a6a47acbf7b5535dcc6989df20ec44b..f164f7d6fdf19e613d80c448d7b1cce535345730 100644 --- a/dbms/src/Common/ZooKeeper/Types.h +++ b/dbms/src/Common/ZooKeeper/Types.h @@ -150,7 +150,7 @@ namespace CreateMode } using EventPtr = std::shared_ptr; -using TaskHandlePtr = DB::BackgroundSchedulePool::TaskHandle; +using TaskHandlePtr = DB::BackgroundSchedulePool::TaskHandle; /// TODO Need to remove this dependency. class ZooKeeper; diff --git a/dbms/src/Common/ZooKeeper/ZooKeeper.cpp b/dbms/src/Common/ZooKeeper/ZooKeeper.cpp index 6af07c94fd7beef835e0c5408d2f264e7d0b35bf..97b753dce795d92c72ed90fd149f9e05b80691eb 100644 --- a/dbms/src/Common/ZooKeeper/ZooKeeper.cpp +++ b/dbms/src/Common/ZooKeeper/ZooKeeper.cpp @@ -273,6 +273,7 @@ int32_t ZooKeeper::getChildrenImpl(const std::string & path, Strings & res, return code; } + Strings ZooKeeper::getChildren( const std::string & path, Stat * stat, const EventPtr & watch) { diff --git a/dbms/src/Interpreters/Context.cpp b/dbms/src/Interpreters/Context.cpp index 2132f172a1cc1958e3a054c8e675299f4899820b..cc2c99d4475be7707c11cb4be6dd5892ccec946c 100644 --- a/dbms/src/Interpreters/Context.cpp +++ b/dbms/src/Interpreters/Context.cpp @@ -1233,7 +1233,7 @@ BackgroundSchedulePool & Context::getSchedulePool() { auto lock = getLock(); if (!shared->schedule_pool) - shared->schedule_pool = std::make_shared(settings.schedule_background_pool_size); + shared->schedule_pool = std::make_shared(settings.background_schedule_pool_size); return *shared->schedule_pool; } diff --git a/dbms/src/Interpreters/Settings.h b/dbms/src/Interpreters/Settings.h index da94020f849bd9b868a8def449fa729dabf48b7f..bcd5ac8230dea5b7b01ed9f34a1f1a49c78a6ccf 100644 --- a/dbms/src/Interpreters/Settings.h +++ b/dbms/src/Interpreters/Settings.h @@ -77,7 +77,7 @@ struct Settings M(SettingUInt64, background_pool_size, DBMS_DEFAULT_BACKGROUND_POOL_SIZE) \ /** Number of threads performing background tasks for replicated tables. \ * TODO: Now only applies when the server is started. You can make it dynamically variable. */ \ - M(SettingUInt64, schedule_background_pool_size, DBMS_DEFAULT_BACKGROUND_POOL_SIZE) \ + M(SettingUInt64, background_schedule_pool_size, DBMS_DEFAULT_BACKGROUND_POOL_SIZE) \ \ /** Sleep time for StorageDistributed DirectoryMonitors in case there is no work or exception has been thrown */ \ M(SettingMilliseconds, distributed_directory_monitor_sleep_time_ms, DBMS_DISTRIBUTED_DIRECTORY_MONITOR_SLEEP_TIME_MS) \ diff --git a/dbms/src/Storages/StorageReplicatedMergeTree.h b/dbms/src/Storages/StorageReplicatedMergeTree.h index a4fb697a10ec8fb0245c02fba600d5b02a87a155..ef6c34f38a1b25af4341af092315006c0a37102f 100644 --- a/dbms/src/Storages/StorageReplicatedMergeTree.h +++ b/dbms/src/Storages/StorageReplicatedMergeTree.h @@ -359,7 +359,7 @@ private: /** Copies the new entries from the logs of all replicas to the queue of this replica. * If next_update_event != nullptr, calls this event when new entries appear in the log. */ - void pullLogsToQueue(BackgroundSchedulePool::TaskHandle = nullptr); + void pullLogsToQueue(BackgroundSchedulePool::TaskHandle next_update_event = nullptr); /** Execute the action from the queue. Throws an exception if something is wrong. * Returns whether or not it succeeds. If it did not work, write it to the end of the queue.