diff options
author | aozeritsky <aozeritsky@ydb.tech> | 2023-10-04 18:16:11 +0300 |
---|---|---|
committer | aozeritsky <aozeritsky@ydb.tech> | 2023-10-04 19:15:38 +0300 |
commit | 2efbbe201fd0733e716f419c73f8557bcaae80e7 (patch) | |
tree | d9268540115c4d77baa910024020afd5413a5c78 | |
parent | 0da82a0a42848f92dbecf6c9510328ede7168f5e (diff) | |
download | ydb-2efbbe201fd0733e716f419c73f8557bcaae80e7.tar.gz |
Fix planner invocation
-rw-r--r-- | ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp | 2 |
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(); |