You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by yi...@apache.org on 2024/02/27 02:15:05 UTC
(doris) 10/15: [fix](scanner) allocated_bytes should be called after success (#31428)
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 <As...@users.noreply.github.com>
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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org