This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 6e62017ed5c35038b6fe354dc7b64e54dd14d305 Author: Ashin Gau <[email protected]> AuthorDate: Mon Feb 26 20:11:27 2024 +0800 [fix](scanner) allocated_bytes should be called after success (#31428) allocated_bytes should be called after success --- be/src/vec/exec/scan/scanner_scheduler.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/vec/exec/scan/scanner_scheduler.cpp b/be/src/vec/exec/scan/scanner_scheduler.cpp index dd3be9f8f3f..f5dfbe4724a 100644 --- a/be/src/vec/exec/scan/scanner_scheduler.cpp +++ b/be/src/vec/exec/scan/scanner_scheduler.cpp @@ -265,7 +265,6 @@ void ScannerScheduler::_scanner_scan(std::shared_ptr<ScannerContext> ctx, break; } status = scanner->get_block_after_projects(state, free_block.get(), &eos); - raw_bytes_read += free_block->allocated_bytes(); first_read = false; // The VFileScanner for external table may try to open not exist files, // Because FE file cache for external table may out of date. @@ -283,6 +282,7 @@ void ScannerScheduler::_scanner_scan(std::shared_ptr<ScannerContext> ctx, eos = true; break; } + raw_bytes_read += free_block->allocated_bytes(); if (!scan_task->cached_blocks.empty() && scan_task->cached_blocks.back()->rows() + free_block->rows() <= ctx->batch_size()) { size_t block_size = scan_task->cached_blocks.back()->allocated_bytes(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
