aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVitalii Gridnev <gridnevvvit@gmail.com>2022-06-02 23:47:41 +0300
committerVitalii Gridnev <gridnevvvit@gmail.com>2022-06-02 23:47:41 +0300
commitc2223fbf0e803777f408d879c541a9fc75efa07e (patch)
tree844f3591e028b449e4417cb5936a88f1f7a2bd81
parent723dc9b7f7c452d7dcb7b3ae01338a7431a98dc2 (diff)
downloadydb-c2223fbf0e803777f408d879c541a9fc75efa07e.tar.gz
[kqp] correctly check sort direction KIKIMR-14818
ref:5b0abeab1b8162eb59a166ceb0262a6c23aec8a8
-rw-r--r--ydb/core/kqp/opt/physical/kqp_opt_phy_sort.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/ydb/core/kqp/opt/physical/kqp_opt_phy_sort.cpp b/ydb/core/kqp/opt/physical/kqp_opt_phy_sort.cpp
index 68073db592..17fa9d1813 100644
--- a/ydb/core/kqp/opt/physical/kqp_opt_phy_sort.cpp
+++ b/ydb/core/kqp/opt/physical/kqp_opt_phy_sort.cpp
@@ -135,7 +135,7 @@ TExprBase KqpRemoveRedundantSortByPk(TExprBase node, TExprContext& ctx, const TK
settings.SetSorted();
input = BuildReadNode(input.Pos(), ctx, input, settings);
- } else if (SortDirectionForward) {
+ } else if (direction == SortDirectionForward) {
if (olapTable) {
auto settings = GetReadTableSettings(input, isReadTableRanges);
settings.SetSorted();