thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-25 09:02:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix linking issue

Browse Source
This commit is contained in:
Konstantin Bogdanov 2024-11-14 11:47:38 +01:00
parent 47bae80a39
commit 769fe98782
No known key found for this signature in database
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/TableFunctions/TableFunctionObjectStorage.cpp
View File

@ -30,7 +30,7 @@ namespace DB
namespace Setting namespace Setting
{ {
extern const SettingsBool use_parallel_replicas; extern const SettingsUInt64 allow_experimental_parallel_reading_from_replicas;
extern const SettingsBool parallel_replicas_for_cluster_engines; extern const SettingsBool parallel_replicas_for_cluster_engines;
extern const SettingsString cluster_for_parallel_replicas; extern const SettingsString cluster_for_parallel_replicas;
extern const SettingsParallelReplicasMode parallel_replicas_mode; extern const SettingsParallelReplicasMode parallel_replicas_mode;
@ -145,7 +145,7 @@ StoragePtr TableFunctionObjectStorage<Definition, Configuration>::executeImpl(
const auto & settings = context->getSettingsRef(); const auto & settings = context->getSettingsRef();
auto parallel_replicas_cluster_name = settings[Setting::cluster_for_parallel_replicas].toString(); auto parallel_replicas_cluster_name = settings[Setting::cluster_for_parallel_replicas].toString();
auto can_use_parallel_replicas = settings[Setting::use_parallel_replicas] auto can_use_parallel_replicas = settings[Setting::allow_experimental_parallel_reading_from_replicas] > 0
&& settings[Setting::parallel_replicas_for_cluster_engines] && settings[Setting::parallel_replicas_for_cluster_engines]
&& settings[Setting::parallel_replicas_mode] == ParallelReplicasMode::READ_TASKS && settings[Setting::parallel_replicas_mode] == ParallelReplicasMode::READ_TASKS
&& !parallel_replicas_cluster_name.empty(); && !parallel_replicas_cluster_name.empty();

5
src/TableFunctions/TableFunctionURL.cpp
View File

@ -24,7 +24,7 @@ namespace DB
namespace Setting namespace Setting
{ {
extern const SettingsBool use_parallel_replicas; extern const SettingsUInt64 allow_experimental_parallel_reading_from_replicas;
extern const SettingsBool parallel_replicas_for_cluster_engines; extern const SettingsBool parallel_replicas_for_cluster_engines;
extern const SettingsString cluster_for_parallel_replicas; extern const SettingsString cluster_for_parallel_replicas;
extern const SettingsParallelReplicasMode parallel_replicas_mode; extern const SettingsParallelReplicasMode parallel_replicas_mode;
@ -152,14 +152,13 @@ StoragePtr TableFunctionURL::getStorage(
const auto & settings = global_context->getSettingsRef(); const auto & settings = global_context->getSettingsRef();
auto parallel_replicas_cluster_name = settings[Setting::cluster_for_parallel_replicas].toString(); auto parallel_replicas_cluster_name = settings[Setting::cluster_for_parallel_replicas].toString();
auto can_use_parallel_replicas = settings[Setting::use_parallel_replicas] auto can_use_parallel_replicas = settings[Setting::allow_experimental_parallel_reading_from_replicas] > 0
&& settings[Setting::parallel_replicas_for_cluster_engines] && settings[Setting::parallel_replicas_for_cluster_engines]
&& settings[Setting::parallel_replicas_mode] == ParallelReplicasMode::READ_TASKS && settings[Setting::parallel_replicas_mode] == ParallelReplicasMode::READ_TASKS
&& !parallel_replicas_cluster_name.empty(); && !parallel_replicas_cluster_name.empty();
if (can_use_parallel_replicas) if (can_use_parallel_replicas)
{ {
LOG_DEBUG(&Poco::Logger::get("TableFunctionURL"), "TableFunctionURL::getStorage wrapped to cluster version");
return std::make_shared<StorageURLCluster>( return std::make_shared<StorageURLCluster>(
global_context, global_context,
settings[Setting::cluster_for_parallel_replicas], settings[Setting::cluster_for_parallel_replicas],