Skip to content

Commit aac2e8a

Browse files
committed
YQL-20237 fix
commit_hash:bd6e641a706a082a31d12e3064aecb994df7b220
1 parent e142e3f commit aac2e8a

File tree

3 files changed

+13
-9
lines changed

3 files changed

+13
-9
lines changed

yql/essentials/providers/common/codec/yql_codec.cpp

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,6 @@ void WriteYsonValueImpl(NResult::TYsonResultWriter& writer, const NUdf::TUnboxed
9292

9393
case NUdf::EDataSlot::String:
9494
case NUdf::EDataSlot::Uuid:
95-
case NUdf::EDataSlot::DyNumber:
9695
writer.OnStringScalar(value.AsStringRef());
9796
return;
9897

@@ -124,7 +123,8 @@ void WriteYsonValueImpl(NResult::TYsonResultWriter& writer, const NUdf::TUnboxed
124123
case NUdf::EDataSlot::TzDate32:
125124
case NUdf::EDataSlot::TzDatetime64:
126125
case NUdf::EDataSlot::TzTimestamp64:
127-
case NUdf::EDataSlot::JsonDocument: {
126+
case NUdf::EDataSlot::JsonDocument:
127+
case NUdf::EDataSlot::DyNumber: {
128128
const NUdf::TUnboxedValue out(ValueToString(*dataType->GetDataSlot(), value));
129129
writer.OnUtf8StringScalar(out.AsStringRef());
130130
return;
@@ -888,7 +888,6 @@ NUdf::TUnboxedValue ReadYsonValue(TType* type,
888888
case NUdf::TDataType<NUdf::TUtf8>::Id:
889889
case NUdf::TDataType<char*>::Id:
890890
case NUdf::TDataType<NUdf::TJson>::Id:
891-
case NUdf::TDataType<NUdf::TDyNumber>::Id:
892891
case NUdf::TDataType<NUdf::TUuid>::Id: {
893892
return ReadYsonStringInResultFormat(cmd, buf);
894893
}
@@ -959,6 +958,11 @@ NUdf::TUnboxedValue ReadYsonValue(TType* type,
959958
return ValueFromString(EDataSlot::JsonDocument, json.AsStringRef());
960959
}
961960

961+
case NUdf::TDataType<NUdf::TDyNumber>::Id: {
962+
const auto str = ReadYsonStringInResultFormat(cmd, buf);
963+
return ValueFromString(EDataSlot::DyNumber, str.AsStringRef());
964+
}
965+
962966
case NUdf::TDataType<NUdf::TTzDate32>::Id: {
963967
auto nextString = ReadNextString(cmd, buf);
964968
NUdf::TUnboxedValuePod data;

yql/essentials/tests/sql/minirun/part1/canondata/result.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,9 @@
3636
],
3737
"test.test[action-eval_data_types-default.txt-Results]": [
3838
{
39-
"checksum": "3ce884c5cc0ae740b88b8798df6f7e3f",
40-
"size": 8779,
41-
"uri": "https://{canondata_backend}/1777230/282d0efe193f0dc3b595b6d46dc07dba9352e2c1/resource.tar.gz#test.test_action-eval_data_types-default.txt-Results_/results.txt"
39+
"checksum": "a96fdaa1e6a6547d07fa552a3e73ba87",
40+
"size": 8713,
41+
"uri": "https://{canondata_backend}/1130705/68f039d0c83dc86b3a5dee401d253486de0d8909/resource.tar.gz#test.test_action-eval_data_types-default.txt-Results_/results.txt"
4242
}
4343
],
4444
"test.test[action-eval_python3_ann--Debug]": [

yql/essentials/tests/sql/minirun/part2/canondata/result.json

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -533,9 +533,9 @@
533533
],
534534
"test.test[expr-cast_dynumber-default.txt-Results]": [
535535
{
536-
"checksum": "926165968058d94728b0ce13c55e5f48",
537-
"size": 3319,
538-
"uri": "https://{canondata_backend}/1946324/e7201814e6e6593b8222695568ac22e9db8f99bc/resource.tar.gz#test.test_expr-cast_dynumber-default.txt-Results_/results.txt"
536+
"checksum": "ca39249ec19dab79c3e83863eae02dbc",
537+
"size": 2985,
538+
"uri": "https://{canondata_backend}/1773845/c113a643cb39c66ba532f769935ab7869ba3ad6b/resource.tar.gz#test.test_expr-cast_dynumber-default.txt-Results_/results.txt"
539539
}
540540
],
541541
"test.test[expr-container_comp-default.txt-Debug]": [

0 commit comments

Comments
 (0)