thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 01:51:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

dbms: Server: Fixed numbering. [#METR-15859]

Browse Source
This commit is contained in:
Alexey Arno 2015-05-05 14:53:09 +03:00
parent 6a3c429bf3
commit 2d8d0970ed
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbms/src/Interpreters/Cluster.cpp
View File

@ -69,7 +69,7 @@ Cluster::Cluster(const Settings & settings, const DataTypeFactory & data_type_fa
const auto & config_prefix = cluster_name + "."; const auto & config_prefix = cluster_name + ".";
UInt32 current_shard_num = 0; UInt32 current_shard_num = 1;
for (auto it = config_keys.begin(); it != config_keys.end(); ++it) for (auto it = config_keys.begin(); it != config_keys.end(); ++it)
{ {
@ -81,7 +81,7 @@ Cluster::Cluster(const Settings & settings, const DataTypeFactory & data_type_fa
continue; continue;
addresses.emplace_back(prefix); addresses.emplace_back(prefix);
addresses.back().replica_num = 0; addresses.back().replica_num = 1;
slot_to_shard.insert(std::end(slot_to_shard), weight, shard_info_vec.size()); slot_to_shard.insert(std::end(slot_to_shard), weight, shard_info_vec.size());
if (const auto is_local = isLocal(addresses.back())) if (const auto is_local = isLocal(addresses.back()))
@ -96,7 +96,7 @@ Cluster::Cluster(const Settings & settings, const DataTypeFactory & data_type_fa
addresses_with_failover.emplace_back(); addresses_with_failover.emplace_back();
Addresses & replica_addresses = addresses_with_failover.back(); Addresses & replica_addresses = addresses_with_failover.back();
UInt32 current_replica_num = 0; UInt32 current_replica_num = 1;
const auto & partial_prefix = config_prefix + *it + "."; const auto & partial_prefix = config_prefix + *it + ".";
const auto weight = config.getInt(partial_prefix + ".weight", 1); const auto weight = config.getInt(partial_prefix + ".weight", 1);