Merge 6e41ab9 into f9cd248

Author: MrLolthe1st

ydb/library/yql/providers/yt/comp_nodes/dq/arrow_converter.cpp

@@ -628,6 +628,12 @@ class TYtColumnConverter final : public IYtColumnConverter {
                 auto result = arrow::compute::Cast(DictPrimitiveConverter_.Convert(block), Settings_.ArrowType);
                 YQL_ENSURE(result.ok());
                 return *result;
+            } else if (Settings_.Type->IsData() && static_cast<NKikimr::NMiniKQL::TDataType*>(Settings_.Type)->GetDataSlot() == NUdf::EDataSlot::Json 
+                && arrow::Type::STRING == Settings_.ArrowType->id() && arrow::Type::BINARY == valType->id())
+            {
+                auto result = arrow::compute::Cast(DictPrimitiveConverter_.Convert(block), Settings_.ArrowType);
+                YQL_ENSURE(result.ok());
+                return *result;
             } else {
                 return DictYsonConverter_.Convert(block);
             }
@@ -640,6 +646,12 @@ class TYtColumnConverter final : public IYtColumnConverter {
                 auto result = arrow::compute::Cast(arrow::Datum(*block), Settings_.ArrowType);
                 YQL_ENSURE(result.ok());
                 return *result;
+            } else if (Settings_.Type->IsData() && static_cast<NKikimr::NMiniKQL::TDataType*>(Settings_.Type)->GetDataSlot() == NUdf::EDataSlot::Json 
+                && arrow::Type::STRING == Settings_.ArrowType->id() && arrow::Type::BINARY == blockType->id())
+            {
+                auto result = arrow::compute::Cast(arrow::Datum(*block), Settings_.ArrowType);
+                YQL_ENSURE(result.ok());
+                return *result;
             } else {
                 YQL_ENSURE(arrow::Type::BINARY == blockType->id());
                 return YsonConverter_.Convert(block);