Skip to content

Commit 02dfc1e

Browse files
committed
push down limit fix (ydb-platform#26130)
1 parent 63dd632 commit 02dfc1e

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
@@ -4227,9 +4227,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
42274227
UNIT_ASSERT_C(status.IsSuccess(), status.GetIssues().ToString());
42284228
TString result = FormatResultSetYson(status.GetResultSet(0));
42294229

4230-
CompareYson(result, R"([])");
4231-
// TODO: FIXME
4232-
// CompareYson(result, R"([[2u]])");
4230+
CompareYson(result, R"([[2u]])");
42334231
}
42344232
}
42354233
}

0 commit comments

Comments
 (0)