Fix scanner resersve memory size

jacktengg · Dec 27, 2024 · 962ddef · 962ddef
1 parent fd5fd00
commit 962ddef
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/be/src/olap/memtable_flush_executor.cpp b/be/src/olap/memtable_flush_executor.cpp
@@ -161,7 +161,7 @@ Status FlushToken::_try_reserve_memory(QueryThreadContext query_thread_context,
         if (memtable_flush_executor->check_and_inc_has_any_flushing_task()) {
             // If there are already any flushing task, Wait for some time and retry.
             LOG_EVERY_T(INFO, 60) << fmt::format(
-                    "Failed to reserve memory {} for flush memtable, retry after 100ms", size);
+                    "Failed to reserve memory {} for flush memtable, retry after 100ms", PrettyPrinter::print_bytes(size));
             std::this_thread::sleep_for(std::chrono::milliseconds(100));
         } else {
             st = Status::OK();

diff --git a/be/src/vec/exec/scan/scanner_scheduler.cpp b/be/src/vec/exec/scan/scanner_scheduler.cpp
@@ -382,7 +382,7 @@ void ScannerScheduler::_scanner_scan(std::shared_ptr<ScannerContext> ctx,
                 }
                 if (scan_task->cached_blocks.back().first->rows() > 0) {
                     auto block_avg_bytes =
-                            (scan_task->cached_blocks.back().first->allocated_bytes() +
+                            (scan_task->cached_blocks.back().first->bytes() +
                              scan_task->cached_blocks.back().first->rows() - 1) /
                             scan_task->cached_blocks.back().first->rows() * ctx->batch_size();
                     scanner->update_block_avg_bytes(block_avg_bytes);