diff options
| author | atarasov5 <[email protected]> | 2025-07-23 16:49:53 +0300 |
|---|---|---|
| committer | atarasov5 <[email protected]> | 2025-07-23 17:06:19 +0300 |
| commit | f88bbf10b144fb4756cf0a7e53c9d45fc1221a70 (patch) | |
| tree | 29c5fab107de1a782560fddd5b1435cdb5f83244 /yql/essentials/minikql/computation/mkql_block_impl.cpp | |
| parent | 85c4f672cdeb513fb546c490c3936ff6e1da6de2 (diff) | |
YQL-20230: Handle singular types in DoConvertScalar
commit_hash:c22dc757dcd7996bac8fb892184281503a2ab003
Diffstat (limited to 'yql/essentials/minikql/computation/mkql_block_impl.cpp')
| -rw-r--r-- | yql/essentials/minikql/computation/mkql_block_impl.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/yql/essentials/minikql/computation/mkql_block_impl.cpp b/yql/essentials/minikql/computation/mkql_block_impl.cpp index 72b4294761c..c178a5bbb7a 100644 --- a/yql/essentials/minikql/computation/mkql_block_impl.cpp +++ b/yql/essentials/minikql/computation/mkql_block_impl.cpp @@ -187,6 +187,10 @@ arrow::Datum DoConvertScalar(TType* type, const T& value, arrow::MemoryPool& poo return NYql::MakePgScalar(AS_TYPE(TPgType, type), value, pool); } + if (IsSingularType(type)) { + return arrow::MakeNullScalar(arrowType); + } + MKQL_ENSURE(false, "Unsupported type " << *type); } |