From e003eaab36090cb8e626fc5755de27001b30d854 Mon Sep 17 00:00:00 2001 From: evenyag Date: Mon, 4 Nov 2024 20:06:20 +0800 Subject: [PATCH] chore: more log --- src/mito2/src/read/scan_util.rs | 6 +++++- src/mito2/src/read/unordered_scan.rs | 4 +++- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/src/mito2/src/read/scan_util.rs b/src/mito2/src/read/scan_util.rs index d27468521a..2adea77b0e 100644 --- a/src/mito2/src/read/scan_util.rs +++ b/src/mito2/src/read/scan_util.rs @@ -163,7 +163,11 @@ pub(crate) fn scan_file_ranges( for range in ranges { let build_reader_start = Instant::now(); let reader = range.reader(None).await?; - part_metrics.inc_build_reader_cost(build_reader_start.elapsed()); + let build_cost = build_reader_start.elapsed(); + part_metrics.inc_build_reader_cost(build_cost); + if read_type == "unordered_scan_files" { + common_telemetry::debug!("Scan file range, region_id: {}, file_id: {}, build_cost: {:?}", stream_ctx.input.mapper.metadata().region_id, range.file_handle().file_id(), build_cost); + } let compat_batch = range.compat_batch(); let mut source = Source::PruneReader(reader); while let Some(mut batch) = source.next_batch().await? { diff --git a/src/mito2/src/read/unordered_scan.rs b/src/mito2/src/read/unordered_scan.rs index 707b7d4ba6..b7d49c4316 100644 --- a/src/mito2/src/read/unordered_scan.rs +++ b/src/mito2/src/read/unordered_scan.rs @@ -188,7 +188,9 @@ impl UnorderedScan { metrics.yield_cost += yield_start.elapsed(); } - metrics.scan_cost += fetch_start.elapsed(); + let scan_cost = fetch_start.elapsed(); + common_telemetry::debug!("Unordered scan range, region_id: {}, scan_cost: {:?}", stream_ctx.input.mapper.metadata().region_id, scan_cost); + metrics.scan_cost += scan_cost; part_metrics.merge_metrics(&metrics); }