aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorivanmorozov <ivanmorozov@yandex-team.com>2023-01-22 15:08:07 +0300
committerivanmorozov <ivanmorozov@yandex-team.com>2023-01-22 15:08:07 +0300
commitdea25c5a5a604da1818e9af47acbaf7e7cfab08f (patch)
treed3e6c7c33f166f08d62c8dc3dde99530c5095e41
parent6271eeec05a7a6a9850b32a3dbfcb45e6839d61a (diff)
downloadydb-dea25c5a5a604da1818e9af47acbaf7e7cfab08f.tar.gz
prepare for multithreading usage permanently
-rw-r--r--ydb/core/kqp/executer_actor/kqp_scan_executer.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/kqp/executer_actor/kqp_scan_executer.cpp b/ydb/core/kqp/executer_actor/kqp_scan_executer.cpp
index 161c70545a..64f3c023d8 100644
--- a/ydb/core/kqp/executer_actor/kqp_scan_executer.cpp
+++ b/ydb/core/kqp/executer_actor/kqp_scan_executer.cpp
@@ -210,7 +210,7 @@ private:
auto& tasks = nodeTasks[nodeId];
auto& cnt = assignedShardsCount[nodeId];
- const ui32 maxScansPerNode = isOlapScan ? 1 : GetMaxTasksPerNodeEstimate(stageInfo);
+ const ui32 maxScansPerNode = isOlapScan ? 16 : GetMaxTasksPerNodeEstimate(stageInfo);
if (cnt < maxScansPerNode) {
auto& task = TasksGraph.AddTask(stageInfo);
task.Meta.NodeId = nodeId;