diff options
author | udovichenko-r <rvu@ydb.tech> | 2022-08-24 18:46:25 +0300 |
---|---|---|
committer | udovichenko-r <rvu@ydb.tech> | 2022-08-24 18:46:25 +0300 |
commit | fed4782791d951fd834c5d9f7be29f408486af1d (patch) | |
tree | 35333ca1920937fc3916a6fa8247639ca28c51f1 | |
parent | 3c2751611185a482c1ac79784578f10197c9dfc4 (diff) | |
download | ydb-fed4782791d951fd834c5d9f7be29f408486af1d.tar.gz |
[dq] Make EnablePorto pragma system only
3 files changed, 4 insertions, 4 deletions
diff --git a/ydb/library/yql/providers/dq/common/yql_dq_settings.cpp b/ydb/library/yql/providers/dq/common/yql_dq_settings.cpp index 333edf948c9..25582f97af6 100644 --- a/ydb/library/yql/providers/dq/common/yql_dq_settings.cpp +++ b/ydb/library/yql/providers/dq/common/yql_dq_settings.cpp @@ -39,7 +39,7 @@ TDqConfiguration::TDqConfiguration() { REGISTER_SETTING(*this, EnableComputeActor); REGISTER_SETTING(*this, ComputeActorType); - REGISTER_SETTING(*this, EnablePorto); + REGISTER_SETTING(*this, _EnablePorto); REGISTER_SETTING(*this, _PortoMemoryLimit); REGISTER_SETTING(*this, EnableFullResultWrite); diff --git a/ydb/library/yql/providers/dq/common/yql_dq_settings.h b/ydb/library/yql/providers/dq/common/yql_dq_settings.h index 11b15bbda02..f30efc7c06d 100644 --- a/ydb/library/yql/providers/dq/common/yql_dq_settings.h +++ b/ydb/library/yql/providers/dq/common/yql_dq_settings.h @@ -64,7 +64,7 @@ struct TDqSettings { NCommon::TConfSetting<bool, false> EnableStrip; NCommon::TConfSetting<bool, false> EnableComputeActor; NCommon::TConfSetting<TString, false> ComputeActorType; - NCommon::TConfSetting<bool, false> EnablePorto; // Will be renamed to _EnablePorto + NCommon::TConfSetting<bool, false> _EnablePorto; NCommon::TConfSetting<ui64, false> _PortoMemoryLimit; NCommon::TConfSetting<bool, false> EnableFullResultWrite; NCommon::TConfSetting<bool, false> _OneGraphPerQuery; @@ -104,7 +104,7 @@ struct TDqSettings { SAVE_SETTING(_AllResultsBytesLimit); SAVE_SETTING(_RowsLimitPerWrite); SAVE_SETTING(EnableComputeActor); - SAVE_SETTING(EnablePorto); + SAVE_SETTING(_EnablePorto); SAVE_SETTING(_PortoMemoryLimit); SAVE_SETTING(EnableFullResultWrite); SAVE_SETTING(_FallbackOnRuntimeErrors); diff --git a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp index 2f2928e37db..2eb74891ae7 100644 --- a/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp +++ b/ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp @@ -1799,7 +1799,7 @@ private: try { conf->Dispatch(settings); } catch (...) { /* ignore unknown settings */ } - portoSettings.Enable = EnablePorto && conf->EnablePorto.Get().GetOrElse(TDqSettings::TDefault::EnablePorto); + portoSettings.Enable = EnablePorto && conf->_EnablePorto.Get().GetOrElse(TDqSettings::TDefault::EnablePorto); portoSettings.MemoryLimit = conf->_PortoMemoryLimit.Get(); if (portoSettings.Enable) { YQL_CLOG(DEBUG, ProviderDq) << "Porto enabled"; |