This commit is contained in:
Nikita Mikhaylov 2021-04-13 23:19:04 +03:00
parent ec35a878d3
commit 2a86d76ccd
2 changed files with 3 additions and 2 deletions

View File

@ -377,7 +377,7 @@ Pipe StorageS3::read(
return glob_iterator->next();
});
}
for (size_t i = 0; i < num_streams; ++i)
{
pipes.emplace_back(std::make_shared<StorageS3Source>(

View File

@ -118,7 +118,8 @@ StoragePtr TableFunctionS3Cluster::executeImpl(
getActualTableStructure(context), ConstraintsDescription{},
context, compression_method, /*distributed_processing=*/true);
}
else {
else
{
storage = StorageS3Cluster::create(
filename, access_key_id, secret_access_key, StorageID(getDatabaseName(), table_name),
cluster_name, format, context->getSettingsRef().s3_max_connections,