diff --git a/be/src/vec/exec/format/csv/csv_reader.cpp b/be/src/vec/exec/format/csv/csv_reader.cpp index ea16234e01..0839d1ed02 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) {