Skip to content

Commit 25fe6e4

Browse files
committed
push down limit fix (ydb-platform#26130)
1 parent 8ff0914 commit 25fe6e4

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
@@ -4433,9 +4433,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) {
44334433
UNIT_ASSERT_C(status.IsSuccess(), status.GetIssues().ToString());
44344434
TString result = FormatResultSetYson(status.GetResultSet(0));
44354435

4436-
CompareYson(result, R"([])");
4437-
// TODO: FIXME
4438-
// CompareYson(result, R"([[2u]])");
4436+
CompareYson(result, R"([[2u]])");
44394437
}
44404438
}
44414439
}

0 commit comments

Comments
 (0)