diff options
author | imunkin <[email protected]> | 2025-08-15 16:59:23 +0300 |
---|---|---|
committer | imunkin <[email protected]> | 2025-08-15 17:16:27 +0300 |
commit | 430679924ce586babc57a97ae2888a00ae4156a9 (patch) | |
tree | 562c7e8748efdceb8a9fd285e404330b6aca07c3 /yql/essentials/minikql/computation | |
parent | 98121ab8bfca78e581350cfccb9af134997f26ef (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.h | 2 |
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(); |