Skip to content

Commit d6575ed

Browse files
fixed issues
1 parent af45a1a commit d6575ed

File tree

1 file changed

+2
-8
lines changed

1 file changed

+2
-8
lines changed

ydb/core/external_sources/object_storage.cpp

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -150,7 +150,7 @@ struct TObjectStorageExternalSource : public IExternalSource {
150150
}
151151
const bool hasPartitioning = objectStorage.projection_size() || objectStorage.partitioned_by_size();
152152
issues.AddIssues(ValidateFormatSetting(objectStorage.format(), objectStorage.format_setting(), location, hasPartitioning));
153-
issues.AddIssues(ValidateSchema(schema, objectStorage.partitioned_by()));
153+
issues.AddIssues(ValidateSchema(schema));
154154
issues.AddIssues(ValidateJsonListFormat(objectStorage.format(), schema, objectStorage.partitioned_by()));
155155
issues.AddIssues(ValidateRawFormat(objectStorage.format(), schema, objectStorage.partitioned_by()));
156156
if (hasPartitioning) {
@@ -270,15 +270,9 @@ struct TObjectStorageExternalSource : public IExternalSource {
270270
}
271271

272272
template<typename TScheme>
273-
static NYql::TIssues ValidateSchema(const TScheme& schema, const google::protobuf::RepeatedPtrField<TString>& partitionedBy) {
273+
static NYql::TIssues ValidateSchema(const TScheme& schema) {
274274
NYql::TIssues issues;
275-
TSet<TString> partitionedBySet{partitionedBy.begin(), partitionedBy.end()};
276-
277275
for (const auto& column: schema.column()) {
278-
if (partitionedBySet.contains(column.name())) {
279-
continue;
280-
}
281-
282276
const auto type = column.type();
283277
if (type.has_optional_type() && type.optional_type().item().has_optional_type()) {
284278
issues.AddIssue(MakeErrorIssue(

0 commit comments

Comments
 (0)