diff --git a/src/IO/ReadBufferFromS3.cpp b/src/IO/ReadBufferFromS3.cpp index 5a95f3009d4..5030e8f2733 100644 --- a/src/IO/ReadBufferFromS3.cpp +++ b/src/IO/ReadBufferFromS3.cpp @@ -319,7 +319,7 @@ SeekableReadBufferPtr ReadBufferS3Factory::getReader() client_ptr, bucket, key, - verion_id, + version_id, s3_max_single_read_retries, read_settings, false /*use_external_buffer*/, diff --git a/src/Storages/StorageS3.cpp b/src/Storages/StorageS3.cpp index d4d13eea120..a370f85954a 100644 --- a/src/Storages/StorageS3.cpp +++ b/src/Storages/StorageS3.cpp @@ -272,7 +272,7 @@ bool StorageS3Source::initialize() file_path = fs::path(bucket) / current_key; - read_buf = wrapReadBufferWithCompressionMethod(createS3ReadBuffer(current_key, version_id), chooseCompressionMethod(current_key, compression_hint)); + read_buf = wrapReadBufferWithCompressionMethod(createS3ReadBuffer(current_key), chooseCompressionMethod(current_key, compression_hint)); auto input_format = getContext()->getInputFormat(format, *read_buf, sample_block, max_block_size, format_settings); QueryPipelineBuilder builder; @@ -291,7 +291,7 @@ bool StorageS3Source::initialize() return true; } -std::unique_ptr StorageS3Source::createS3ReadBuffer(const String & key, const String & version_id) +std::unique_ptr StorageS3Source::createS3ReadBuffer(const String & key) { const size_t object_size = DB::S3::getObjectSize(client, bucket, key, version_id, false); diff --git a/src/Storages/StorageS3.h b/src/Storages/StorageS3.h index 8000f8802d8..198f75e3e81 100644 --- a/src/Storages/StorageS3.h +++ b/src/Storages/StorageS3.h @@ -112,7 +112,7 @@ private: /// Recreate ReadBuffer and BlockInputStream for each file. bool initialize(); - std::unique_ptr createS3ReadBuffer(const String & key, const String & version_id); + std::unique_ptr createS3ReadBuffer(const String & key); }; /**