diff --git a/ydb/core/formats/arrow/program/filter.cpp b/ydb/core/formats/arrow/program/filter.cpp index 2fad9db6f43a..0ba1f44bf313 100644 --- a/ydb/core/formats/arrow/program/filter.cpp +++ b/ydb/core/formats/arrow/program/filter.cpp @@ -104,8 +104,8 @@ TConclusion TFilterProcessor::DoExecute( AFL_VERIFY(filter.GetRecordsCountVerified() == inputColumns.front()->GetRecordsCount())("filter", filter.GetRecordsCountVerified())( "input", inputColumns.front()->GetRecordsCount()); if (context.GetLimit()) { - context.MutableResources().AddFilter( - filter.Cut(context.GetResources().GetRecordsCountRobustVerified(), *context.GetLimit(), context.GetReverse())); + context.MutableResources().AddFilter(filter); + context.MutableResources().CutFilter(context.GetResources().GetRecordsCountRobustVerified(), *context.GetLimit(), context.GetReverse()); } else { context.MutableResources().AddFilter(filter); } diff --git a/ydb/core/kqp/ut/olap/kqp_olap_ut.cpp b/ydb/core/kqp/ut/olap/kqp_olap_ut.cpp index 4f1458eaee23..e3e2c21538ed 100644 --- a/ydb/core/kqp/ut/olap/kqp_olap_ut.cpp +++ b/ydb/core/kqp/ut/olap/kqp_olap_ut.cpp @@ -4741,9 +4741,7 @@ Y_UNIT_TEST_SUITE(KqpOlap) { UNIT_ASSERT_C(status.IsSuccess(), status.GetIssues().ToString()); TString result = FormatResultSetYson(status.GetResultSet(0)); - CompareYson(result, R"([])"); - // TODO: FIXME - // CompareYson(result, R"([[2u]])"); + CompareYson(result, R"([[2u]])"); } } }