aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhor911 <hor911@ydb.tech>2023-08-30 18:06:26 +0300
committerhor911 <hor911@ydb.tech>2023-08-30 18:54:59 +0300
commit87c0c1a041ba727af4306729d692554f251a2aa0 (patch)
treeb1e1e206d799162c312fa89c27c03cd82f256c37
parent6420e048afe32b6590f6b52f9fc6ffdcfab642ba (diff)
downloadydb-87c0c1a041ba727af4306729d692554f251a2aa0.tar.gz
Keep Shuffle Stage Count
Давным давно на шаффле делили количество тасок пополам. Позже это было признано неудачным решением, особенно с распределенным grace join. В тестах лучше всего показывает себя ratio = 1, то есть количество тасок после шаффла сохраняется. Пока что не выношу ratio в настройки, просто фиксирую константой
-rw-r--r--ydb/core/kqp/executer_actor/kqp_data_executer.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/kqp/executer_actor/kqp_data_executer.cpp b/ydb/core/kqp/executer_actor/kqp_data_executer.cpp
index a6c26a6988..95314b54fd 100644
--- a/ydb/core/kqp/executer_actor/kqp_data_executer.cpp
+++ b/ydb/core/kqp/executer_actor/kqp_data_executer.cpp
@@ -1522,7 +1522,7 @@ private:
switch (input.GetTypeCase()) {
case NKqpProto::TKqpPhyConnection::kHashShuffle: {
- partitionsCount = std::max(partitionsCount, (ui32)originStageInfo.Tasks.size() / 2);
+ partitionsCount = std::max(partitionsCount, (ui32)originStageInfo.Tasks.size());
partitionsCount = std::min(partitionsCount, 24u);
break;
}