aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authora-romanov <Anton.Romanov@ydb.tech>2022-09-16 18:32:30 +0300
committera-romanov <Anton.Romanov@ydb.tech>2022-09-16 18:32:30 +0300
commitfc6228adb13e707d9218f74d753d669dd3950c66 (patch)
treefecff8a7606fd7868a97353257f2976220c31bba
parent5e727bfc30a793941d168ef1e511ae4ebd344511 (diff)
downloadydb-fc6228adb13e707d9218f74d753d669dd3950c66.tar.gz
fix.
-rw-r--r--ydb/library/yql/providers/s3/provider/yql_s3_io_discovery.cpp8
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();