diff options
| -rw-r--r-- | ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp | 1 | ||||
| -rw-r--r-- | ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp | 6 |
2 files changed, 3 insertions, 4 deletions
diff --git a/ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp b/ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp index 71fabca7d0..751d192931 100644 --- a/ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp +++ b/ydb/library/yql/providers/yt/gateway/native/yql_yt_native.cpp @@ -2982,7 +2982,6 @@ private: execCtx->Options_.OptLLVM()), &columns, execCtx->Options_.FillSettings().Format); - break; default: YQL_LOG_CTX_THROW yexception() << "Invalid result type: " << execCtx->Options_.FillSettings().Format; } diff --git a/ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp b/ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp index ada1131e5b..f8da0dbb91 100644 --- a/ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp +++ b/ydb/library/yql/providers/yt/lib/res_pull/res_or_pull.cpp @@ -134,9 +134,9 @@ bool TSkiffExecuteResOrPull::WriteNext(const NYT::TNode& item) { } TStringStream err; - auto value = NCommon::ParseYsonNode(HolderFactory, item, Specs.Outputs[0].RowType, &err); + auto value = NCommon::ParseYsonNodeInResultFormat(HolderFactory, item, Specs.Outputs[0].RowType, &err); if (!value) { - throw yexception() << "Could not parse yson node"; + throw yexception() << "Could not parse yson node with error: " << err.Str(); } SkiffWriter.AddRow(*value); @@ -169,7 +169,7 @@ bool TSkiffExecuteResOrPull::WriteNext(TMkqlIOCache& specsCache, const NYT::TNod TStringStream err; auto value = NCommon::ParseYsonNode(specsCache.GetHolderFactory(), rec, Specs.Outputs[tableIndex].RowType, &err); if (!value) { - throw yexception() << "Could not parse yson node"; + throw yexception() << "Could not parse yson node with error: " << err.Str(); } SkiffWriter.AddRow(*value); |