This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 9006e2b8a51 [fix](prefetch-read) make prefetch range correct to
accelerate S3 load and fix its speed unbalance (#25775)
9006e2b8a51 is described below
commit 9006e2b8a51ff796c39d183cb6e608e3b4987a7d
Author: Siyang Tang <82279870+tangsiyang2...@users.noreply.github.com>
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 ea16234e016..0839d1ed026 100644
--- a/be/src/vec/exec/format/csv/csv_reader.cpp
+++ b/be/src/vec/exec/format/csv/csv_reader.cpp
@@ -303,7 +303,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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
