diff options
author | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-01-22 15:08:07 +0300 |
---|---|---|
committer | ivanmorozov <ivanmorozov@yandex-team.com> | 2023-01-22 15:08:07 +0300 |
commit | dea25c5a5a604da1818e9af47acbaf7e7cfab08f (patch) | |
tree | d3e6c7c33f166f08d62c8dc3dde99530c5095e41 | |
parent | 6271eeec05a7a6a9850b32a3dbfcb45e6839d61a (diff) | |
download | ydb-dea25c5a5a604da1818e9af47acbaf7e7cfab08f.tar.gz |
prepare for multithreading usage permanently
-rw-r--r-- | ydb/core/kqp/executer_actor/kqp_scan_executer.cpp | 2 |
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; |