diff options
| author | hor911 <hor911@ydb.tech> | 2023-10-17 16:05:46 +0300 |
|---|---|---|
| committer | hor911 <hor911@ydb.tech> | 2023-10-17 17:02:09 +0300 |
| commit | cf5b6afa0a2fe876a363f55314e5fe13ae66fc1b (patch) | |
| tree | 4529d7f7d309e430940208894da2e9294ddfafca | |
| parent | 370361b9e5649ee21ee34d73fec19194657629e0 (diff) | |
| download | ydb-cf5b6afa0a2fe876a363f55314e5fe13ae66fc1b.tar.gz | |
Remove limit of 24 task per shuffle stage
| -rw-r--r-- | ydb/core/kqp/executer_actor/kqp_data_executer.cpp | 1 |
1 files changed, 0 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 2a53e5310e..216879297a 100644 --- a/ydb/core/kqp/executer_actor/kqp_data_executer.cpp +++ b/ydb/core/kqp/executer_actor/kqp_data_executer.cpp @@ -1510,7 +1510,6 @@ private: switch (input.GetTypeCase()) { case NKqpProto::TKqpPhyConnection::kHashShuffle: { partitionsCount = std::max(partitionsCount, (ui32)originStageInfo.Tasks.size()); - partitionsCount = std::min(partitionsCount, 24u); break; } |