thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-11 08:52:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

[Storages] bugfix

Browse Source 
Corrected order of parameters by swapping bucket and versionId.
This commit is contained in:
Saad Ur Rahman 2022-03-14 22:20:02 -04:00
parent d9b370cf1d
commit fb450b7068
No known key found for this signature in database
GPG Key ID: C6773CD21542E49C
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Storages/StorageS3.cpp
View File

@ -274,7 +274,7 @@ bool StorageS3Source::initialize()
file_path = fs::path(bucket) / current_key;
read_buf = wrapReadBufferWithCompressionMethod(
std::make_unique<ReadBufferFromS3>(client, bucket, version_id, current_key, max_single_read_retries, getContext()->getReadSettings()),
std::make_unique<ReadBufferFromS3>(client, bucket, current_key, version_id, max_single_read_retries, getContext()->getReadSettings()),
chooseCompressionMethod(current_key, compression_hint));
auto input_format = getContext()->getInputFormat(format, *read_buf, sample_block, max_block_size, format_settings);
QueryPipelineBuilder builder;
@ -929,8 +929,8 @@ ColumnsDescription StorageS3::getTableStructureFromDataImpl(
std::make_unique<ReadBufferFromS3>(
client_auth.client,
client_auth.uri.bucket,
client_auth.uri.version_id,
current_key,
client_auth.uri.version_id,
max_single_read_retries,
ctx->getReadSettings()),
chooseCompressionMethod(current_key, compression_method));