You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2023/10/23 12:02:32 UTC
[doris] branch master updated: [fix](prefetch-read) make prefetch range correct to accelerate S3 load and fix its speed unbalance (#25775)
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 <82...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org