diff options
| author | hor911 <hor911@ydb.tech> | 2022-07-12 23:29:48 +0300 |
|---|---|---|
| committer | hor911 <hor911@ydb.tech> | 2022-07-12 23:29:48 +0300 |
| commit | ca41e150f41ddc5bd631a17f3857a0f10ee646dd (patch) | |
| tree | 7d1b3647470c8970c92a08053235189d4a8f987e | |
| parent | b45e6cd1ddfb0790202c31035f13acd3bfe33dd9 (diff) | |
| download | ydb-ca41e150f41ddc5bd631a17f3857a0f10ee646dd.tar.gz | |
UseDataCenter feature flag
| -rw-r--r-- | ydb/core/yq/libs/actors/nodes_manager.cpp | 4 | ||||
| -rw-r--r-- | ydb/core/yq/libs/config/protos/nodes_manager.proto | 1 | ||||
| -rw-r--r-- | ydb/core/yq/libs/init/init.cpp | 2 |
3 files changed, 4 insertions, 3 deletions
diff --git a/ydb/core/yq/libs/actors/nodes_manager.cpp b/ydb/core/yq/libs/actors/nodes_manager.cpp index 5b877de222e..7edd6962f78 100644 --- a/ydb/core/yq/libs/actors/nodes_manager.cpp +++ b/ydb/core/yq/libs/actors/nodes_manager.cpp @@ -42,7 +42,7 @@ public: const ::NYql::NCommon::TServiceCounters& serviceCounters, const NConfig::TPrivateApiConfig& privateApiConfig, const ui32& icPort, - const TString&, + const TString& dataCenter, const TString& tenant, ui64 mkqlInitialMemoryLimit) : WorkerManagerCounters(workerManagerCounters) @@ -54,7 +54,7 @@ public: , MkqlInitialMemoryLimit(mkqlInitialMemoryLimit) , YqSharedResources(yqSharedResources) , IcPort(icPort) - , DataCenter("") + , DataCenter(dataCenter) , InternalServiceId(MakeInternalServiceActorId()) { diff --git a/ydb/core/yq/libs/config/protos/nodes_manager.proto b/ydb/core/yq/libs/config/protos/nodes_manager.proto index 5b390d3ba05..8d0cf28df26 100644 --- a/ydb/core/yq/libs/config/protos/nodes_manager.proto +++ b/ydb/core/yq/libs/config/protos/nodes_manager.proto @@ -11,4 +11,5 @@ message TNodesManagerConfig { uint32 Port = 2; string Host = 3; string DataCenter = 4; + bool UseDataCenter = 5; } diff --git a/ydb/core/yq/libs/init/init.cpp b/ydb/core/yq/libs/init/init.cpp index c8c1c304267..9decec3291b 100644 --- a/ydb/core/yq/libs/init/init.cpp +++ b/ydb/core/yq/libs/init/init.cpp @@ -207,7 +207,7 @@ void Init( protoConfig.GetPrivateApi(), yqSharedResources, icPort, - protoConfig.GetNodesManager().GetDataCenter(), + protoConfig.GetNodesManager().GetUseDataCenter() ? protoConfig.GetNodesManager().GetDataCenter() : "", tenant, mkqlInitialMemoryLimit); |