diff options
| author | hor911 <hor911@ydb.tech> | 2023-02-12 20:03:02 +0300 |
|---|---|---|
| committer | hor911 <hor911@ydb.tech> | 2023-02-12 20:03:02 +0300 |
| commit | d7b9667f8fffe1124d39faaf4a923ffa3012f2fc (patch) | |
| tree | 51de3a4f051804273c62a3a480b55753bbec33ed | |
| parent | e36071919caa6b9ff580c06fd8f347f352b4dc6e (diff) | |
| download | ydb-d7b9667f8fffe1124d39faaf4a923ffa3012f2fc.tar.gz | |
Configurable MaxTasksPerStage Hard Limit
| -rw-r--r-- | ydb/core/yq/libs/actors/run_actor.cpp | 4 | ||||
| -rw-r--r-- | ydb/core/yq/libs/config/protos/common.proto | 1 |
2 files changed, 4 insertions, 1 deletions
diff --git a/ydb/core/yq/libs/actors/run_actor.cpp b/ydb/core/yq/libs/actors/run_actor.cpp index 36d2e88f22f..383479a774b 100644 --- a/ydb/core/yq/libs/actors/run_actor.cpp +++ b/ydb/core/yq/libs/actors/run_actor.cpp @@ -282,6 +282,7 @@ public: , CreatedAt(Params.CreatedAt) , QueryCounters(queryCounters) , EnableCheckpointCoordinator(Params.QueryType == YandexQuery::QueryContent::STREAMING && Params.CheckpointCoordinatorConfig.GetEnabled()) + , MaxTasksPerStage(Params.CommonConfig.GetMaxTasksPerStage() ? Params.CommonConfig.GetMaxTasksPerStage() : 500) , MaxTasksPerOperation(Params.CommonConfig.GetMaxTasksPerOperation() ? Params.CommonConfig.GetMaxTasksPerOperation() : 40) , Compressor(Params.CommonConfig.GetQueryArtifactsCompressionMethod(), Params.CommonConfig.GetQueryArtifactsCompressionMinSize()) { @@ -1415,7 +1416,7 @@ private: } }; - apply("MaxTasksPerStage", "500"); + apply("MaxTasksPerStage", ToString(MaxTasksPerStage)); apply("MaxTasksPerOperation", ToString(MaxTasksPerOperation)); apply("EnableComputeActor", "1"); apply("ComputeActorType", "async"); @@ -1963,6 +1964,7 @@ private: bool EnableCheckpointCoordinator = false; Fq::Private::PingTaskRequest QueryStateUpdateRequest; + const ui64 MaxTasksPerStage; const ui64 MaxTasksPerOperation; const TCompressor Compressor; diff --git a/ydb/core/yq/libs/config/protos/common.proto b/ydb/core/yq/libs/config/protos/common.proto index b839c6a62d6..a657cbed22c 100644 --- a/ydb/core/yq/libs/config/protos/common.proto +++ b/ydb/core/yq/libs/config/protos/common.proto @@ -24,4 +24,5 @@ message TCommonConfig { string QueryArtifactsCompressionMethod = 9; uint64 QueryArtifactsCompressionMinSize = 10; string MonitoringEndpoint = 11; + uint64 MaxTasksPerStage = 12; } |