aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraozeritsky <aozeritsky@ydb.tech>2023-10-04 18:16:11 +0300
committeraozeritsky <aozeritsky@ydb.tech>2023-10-04 19:15:38 +0300
commit2efbbe201fd0733e716f419c73f8557bcaae80e7 (patch)
treed9268540115c4d77baa910024020afd5413a5c78
parent0da82a0a42848f92dbecf6c9510328ede7168f5e (diff)
downloadydb-2efbbe201fd0733e716f419c73f8557bcaae80e7.tar.gz
Fix planner invocation
-rw-r--r--ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
index 29dd72743e9..fdd6619ae2d 100644
--- a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
+++ b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
@@ -1589,7 +1589,7 @@ private:
YQL_ENSURE(stagesCount <= maxTasksPerOperation);
try {
- while (executionPlanner->PlanExecution(canFallback) > maxTasksPerOperation && tasksPerStage > 1) {
+ while (!executionPlanner->PlanExecution(canFallback) && tasksPerStage > 1) {
tasksPerStage /= 2;
settings->MaxTasksPerStage = tasksPerStage;
executionPlanner->Clear();