diff options
author | hor911 <hor911@ydb.tech> | 2023-08-30 18:06:26 +0300 |
---|---|---|
committer | hor911 <hor911@ydb.tech> | 2023-08-30 18:54:59 +0300 |
commit | 87c0c1a041ba727af4306729d692554f251a2aa0 (patch) | |
tree | b1e1e206d799162c312fa89c27c03cd82f256c37 | |
parent | 6420e048afe32b6590f6b52f9fc6ffdcfab642ba (diff) | |
download | ydb-87c0c1a041ba727af4306729d692554f251a2aa0.tar.gz |
Keep Shuffle Stage Count
Давным давно на шаффле делили количество тасок пополам. Позже это было признано неудачным решением, особенно с распределенным grace join. В тестах лучше всего показывает себя ratio = 1, то есть количество тасок после шаффла сохраняется. Пока что не выношу ratio в настройки, просто фиксирую константой
-rw-r--r-- | ydb/core/kqp/executer_actor/kqp_data_executer.cpp | 2 |
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; } |