summaryrefslogtreecommitdiffstats
path: root/yql/essentials/minikql/computation
diff options
context:
space:
mode:
authorimunkin <[email protected]>2025-08-15 16:59:23 +0300
committerimunkin <[email protected]>2025-08-15 17:16:27 +0300
commit430679924ce586babc57a97ae2888a00ae4156a9 (patch)
tree562c7e8748efdceb8a9fd285e404330b6aca07c3 /yql/essentials/minikql/computation
parent98121ab8bfca78e581350cfccb9af134997f26ef (diff)
YQL-20304: Handle Skip for singular multi type properly
commit_hash:d3b2d5b7f166b837c20902da616785f358666a4a
Diffstat (limited to 'yql/essentials/minikql/computation')
-rw-r--r--yql/essentials/minikql/computation/mkql_simple_codegen.h2
1 files changed, 1 insertions, 1 deletions
diff --git a/yql/essentials/minikql/computation/mkql_simple_codegen.h b/yql/essentials/minikql/computation/mkql_simple_codegen.h
index 1294abe06c5..ce2f74148c0 100644
--- a/yql/essentials/minikql/computation/mkql_simple_codegen.h
+++ b/yql/essentials/minikql/computation/mkql_simple_codegen.h
@@ -115,7 +115,7 @@ public:
auto result = TMaybeFetchResult::None();
while (result.Empty()) {
NUdf::TUnboxedValue*const* input = static_cast<const TDerived*>(this)->PrepareInput(state, ctx, output);
- TMaybeFetchResult fetchResult = input ? SourceFlow->FetchValues(ctx, input) : TMaybeFetchResult::None();
+ TMaybeFetchResult fetchResult = input || !InWidth ? SourceFlow->FetchValues(ctx, input) : TMaybeFetchResult::None();
result = static_cast<const TDerived*>(this)->DoProcess(state, ctx, fetchResult, output);
}
return result.Get();