Skip to content

Commit b300d8e

Browse files
authored
push down limit fix (#26130)
1 parent b95d598 commit b300d8e

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

ydb/core/formats/arrow/program/filter.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -104,8 +104,8 @@ TConclusion<IResourceProcessor::EExecutionResult> TFilterProcessor::DoExecute(
104104
AFL_VERIFY(filter.GetRecordsCountVerified() == inputColumns.front()->GetRecordsCount())("filter", filter.GetRecordsCountVerified())(
105105
"input", inputColumns.front()->GetRecordsCount());
106106
if (context.GetLimit()) {
107-
context.MutableResources().AddFilter(
108-
filter.Cut(context.GetResources().GetRecordsCountRobustVerified(), *context.GetLimit(), context.GetReverse()));
107+
context.MutableResources().AddFilter(filter);
108+
context.MutableResources().CutFilter(context.GetResources().GetRecordsCountRobustVerified(), *context.GetLimit(), context.GetReverse());
109109
} else {
110110
context.MutableResources().AddFilter(filter);
111111
}

ydb/core/kqp/ut/olap/kqp_olap_ut.cpp

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4741,9 +4741,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
47414741
UNIT_ASSERT_C(status.IsSuccess(), status.GetIssues().ToString());
47424742
TString result = FormatResultSetYson(status.GetResultSet(0));
47434743

4744-
CompareYson(result, R"([])");
4745-
// TODO: FIXME
4746-
// CompareYson(result, R"([[2u]])");
4744+
CompareYson(result, R"([[2u]])");
47474745
}
47484746
}
47494747
}

0 commit comments

Comments
 (0)