aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorudovichenko-r <rvu@ydb.tech>2022-08-24 18:46:25 +0300
committerudovichenko-r <rvu@ydb.tech>2022-08-24 18:46:25 +0300
commitfed4782791d951fd834c5d9f7be29f408486af1d (patch)
tree35333ca1920937fc3916a6fa8247639ca28c51f1
parent3c2751611185a482c1ac79784578f10197c9dfc4 (diff)
downloadydb-fed4782791d951fd834c5d9f7be29f408486af1d.tar.gz
[dq] Make EnablePorto pragma system only
-rw-r--r--ydb/library/yql/providers/dq/common/yql_dq_settings.cpp2
-rw-r--r--ydb/library/yql/providers/dq/common/yql_dq_settings.h4
-rw-r--r--ydb/library/yql/providers/dq/task_runner/tasks_runner_pipe.cpp2
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";