diff options
author | aneporada <aneporada@ydb.tech> | 2023-08-30 12:48:15 +0300 |
---|---|---|
committer | aneporada <aneporada@ydb.tech> | 2023-08-30 13:48:44 +0300 |
commit | d211395d364252c63eb2824a57d7966afd123ce6 (patch) | |
tree | c7f2d10d7f863791165438bc81e5f5dabae11cd9 | |
parent | aec8d0c5a9d4ff5c67d5a85ac4c642b8ecc25590 (diff) | |
download | ydb-d211395d364252c63eb2824a57d7966afd123ce6.tar.gz |
Add missing types to CalcMaxBlockItemSize(). Improve logging
-rw-r--r-- | ydb/library/yql/minikql/mkql_type_builder.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/ydb/library/yql/minikql/mkql_type_builder.cpp b/ydb/library/yql/minikql/mkql_type_builder.cpp index e4ec0473d0c..abab15a9f89 100644 --- a/ydb/library/yql/minikql/mkql_type_builder.cpp +++ b/ydb/library/yql/minikql/mkql_type_builder.cpp @@ -2398,17 +2398,20 @@ size_t CalcMaxBlockItemSize(const TType* type) { return sz; } case NUdf::EDataSlot::String: + case NUdf::EDataSlot::Yson: + case NUdf::EDataSlot::JsonDocument: // size of offset part return sizeof(arrow::BinaryType::offset_type); case NUdf::EDataSlot::Utf8: + case NUdf::EDataSlot::Json: // size of offset part return sizeof(arrow::StringType::offset_type); default: - MKQL_ENSURE(false, "Unsupported data slot"); + MKQL_ENSURE(false, "Unsupported data slot: " << slot); } } - MKQL_ENSURE(false, "Unsupported type"); + MKQL_ENSURE(false, "Unsupported type: " << *type); } struct TComparatorTraits { |