diff options
author | a-romanov <Anton.Romanov@ydb.tech> | 2022-09-16 18:32:30 +0300 |
---|---|---|
committer | a-romanov <Anton.Romanov@ydb.tech> | 2022-09-16 18:32:30 +0300 |
commit | fc6228adb13e707d9218f74d753d669dd3950c66 (patch) | |
tree | fecff8a7606fd7868a97353257f2976220c31bba | |
parent | 5e727bfc30a793941d168ef1e511ae4ebd344511 (diff) | |
download | ydb-fc6228adb13e707d9218f74d753d669dd3950c66.tar.gz |
fix.
-rw-r--r-- | ydb/library/yql/providers/s3/provider/yql_s3_io_discovery.cpp | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/s3/provider/yql_s3_io_discovery.cpp b/ydb/library/yql/providers/s3/provider/yql_s3_io_discovery.cpp index ba69643da93..8f5f635a226 100644 --- a/ydb/library/yql/providers/s3/provider/yql_s3_io_discovery.cpp +++ b/ydb/library/yql/providers/s3/provider/yql_s3_io_discovery.cpp @@ -270,10 +270,16 @@ public: continue; } + auto format = ExtractFormat(settings); + if (!format) { + ctx.AddError(TIssue(ctx.GetPosition(read.Ref().Child(4)->Pos()), "No read format specified.")); + return TStatus::Error; + } + TExprNode::TPtr s3Object; s3Object = Build<TS3Object>(ctx, object.Pos()) .Paths(ctx.NewList(object.Pos(), std::move(pathNodes))) - .Format(ExtractFormat(settings)) + .Format(std::move(format)) .Settings(ctx.NewList(object.Pos(), std::move(settings))) .Done().Ptr(); |