This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit b58f1a68c7c4ca6c43cd54a46cdd88656e35580e Author: Siyang Tang <[email protected]> AuthorDate: Mon Oct 23 20:02:24 2023 +0800 [fix](prefetch-read) make prefetch range correct to accelerate S3 load and fix its speed unbalance (#25775) --- be/src/vec/exec/format/csv/csv_reader.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/vec/exec/format/csv/csv_reader.cpp b/be/src/vec/exec/format/csv/csv_reader.cpp index 70a691f5d66..46bb5540e4b 100644 --- a/be/src/vec/exec/format/csv/csv_reader.cpp +++ b/be/src/vec/exec/format/csv/csv_reader.cpp @@ -304,7 +304,7 @@ Status CsvReader::init_reader(bool is_load) { RETURN_IF_ERROR(io::DelegateReader::create_file_reader( _profile, _system_properties, _file_description, reader_options, &_file_system, &_file_reader, io::DelegateReader::AccessMode::SEQUENTIAL, _io_ctx, - io::PrefetchRange(_range.start_offset, _range.size))); + io::PrefetchRange(_range.start_offset, _range.start_offset + _range.size))); } if (_file_reader->size() == 0 && _params.file_type != TFileType::FILE_STREAM && _params.file_type != TFileType::FILE_BROKER) { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
