diff options
| author | hcpp <hcpp@ydb.tech> | 2023-03-01 14:51:15 +0300 |
|---|---|---|
| committer | hcpp <hcpp@ydb.tech> | 2023-03-01 14:51:15 +0300 |
| commit | e1562439ec58ebe106f3ddce6de45c32617cb3f1 (patch) | |
| tree | f9cb093e33d1c60a8cea310db5f27f3e19caed4f | |
| parent | 76f6489f2f2444caf5a8712cb5597f333e9ce53c (diff) | |
| download | ydb-e1562439ec58ebe106f3ddce6de45c32617cb3f1.tar.gz | |
check for discovery per node has been added
| -rw-r--r-- | ydb/library/yql/providers/s3/provider/yql_s3_io_discovery.cpp | 5 |
1 files changed, 5 insertions, 0 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 d37b8de5215..065b37b57ad 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 @@ -782,6 +782,11 @@ private: } } + if (!reqs) { + ctx.AddError(TIssue(ctx.GetPosition(read.Pos()), TStringBuilder() << "Path prefix: '" << path << "' empty list for discovery")); + return false; + } + for (auto& req : reqs) { RequestsByNode_[read.Raw()].push_back(req); if (PendingRequests_.find(req) == PendingRequests_.end()) { |