diff --git a/src/Storages/StorageS3.cpp b/src/Storages/StorageS3.cpp index 84d6b7a3b4b..c2632362fc2 100644 --- a/src/Storages/StorageS3.cpp +++ b/src/Storages/StorageS3.cpp @@ -199,7 +199,7 @@ bool StorageS3Source::initialize() file_path = bucket + "/" + current_key; read_buf = wrapReadBufferWithCompressionMethod( - std::make_unique(client, bucket, current_key), chooseCompressionMethod(current_key, compression_hint)); + std::make_unique(client, bucket, current_key, s3_max_single_read_retries), chooseCompressionMethod(current_key, compression_hint)); auto input_format = FormatFactory::instance().getInput(format, *read_buf, sample_block, getContext(), max_block_size); reader = std::make_shared(input_format);