From 9a6c7aa4d60f98de9079bf161d0aa07b045acebb Mon Sep 17 00:00:00 2001 From: evenyag Date: Fri, 8 Nov 2024 01:08:02 +0800 Subject: [PATCH] chore: log label --- src/mito2/src/read/scan_region.rs | 8 ++++---- src/mito2/src/read/scan_util.rs | 6 +++--- src/mito2/src/read/unordered_scan.rs | 6 +++--- 3 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/mito2/src/read/scan_region.rs b/src/mito2/src/read/scan_region.rs index 6b5675454b..1ef1e527a8 100644 --- a/src/mito2/src/read/scan_region.rs +++ b/src/mito2/src/read/scan_region.rs @@ -918,7 +918,7 @@ impl RangeBuilderList { let file_index = index.index - self.mem_builders.len(); if read_type == "unordered_scan_files" { common_telemetry::debug!( - "RangeBuilderList build ranges start, region_id: {}, row_group_index: {:?}", + "[DEBUG_SCAN] RangeBuilderList build ranges start, region_id: {}, row_group_index: {:?}", input.mapper.metadata().region_id, index, ); @@ -928,7 +928,7 @@ impl RangeBuilderList { Some(builder) => { if read_type == "unordered_scan_files" { common_telemetry::debug!( - "RangeBuilderList build ranges get lock, build ranges, region_id: {}, row_group_index: {:?}", + "[DEBUG_SCAN] RangeBuilderList build ranges get lock, build ranges, region_id: {}, row_group_index: {:?}", input.mapper.metadata().region_id, index, ); @@ -938,7 +938,7 @@ impl RangeBuilderList { None => { if read_type == "unordered_scan_files" { common_telemetry::debug!( - "RangeBuilderList build ranges get lock, build builder, region_id: {}, row_group_index: {:?}", + "[DEBUG_SCAN] RangeBuilderList build ranges get lock, build builder, region_id: {}, row_group_index: {:?}", input.mapper.metadata().region_id, index, ); @@ -951,7 +951,7 @@ impl RangeBuilderList { if read_type == "unordered_scan_files" { common_telemetry::debug!( - "RangeBuilderList build ranges end, region_id: {}, row_group_index: {:?}, ranges: {}", + "[DEBUG_SCAN] RangeBuilderList build ranges end, region_id: {}, row_group_index: {:?}, ranges: {}", input.mapper.metadata().region_id, index, ranges.len(), diff --git a/src/mito2/src/read/scan_util.rs b/src/mito2/src/read/scan_util.rs index 70121f8e77..572f006858 100644 --- a/src/mito2/src/read/scan_util.rs +++ b/src/mito2/src/read/scan_util.rs @@ -183,7 +183,7 @@ pub(crate) fn scan_file_ranges( let mut reader_metrics = ReaderMetrics::default(); if read_type == "unordered_scan_files" { common_telemetry::debug!( - "Thread: {:?}, Scan file ranges build ranges start, region_id: {}, partition: {}, index: {:?}", + "[DEBUG_SCAN] Thread: {:?}, Scan file ranges build ranges start, region_id: {}, partition: {}, index: {:?}", std::thread::current().id(), stream_ctx.input.mapper.metadata().region_id, partition, @@ -196,7 +196,7 @@ pub(crate) fn scan_file_ranges( part_metrics.inc_num_file_ranges(ranges.len()); if read_type == "unordered_scan_files" { common_telemetry::debug!( - "Thread: {:?}, Scan file ranges build ranges end, region_id: {}, partition: {}, index: {:?}, ranges: {}", + "[DEBUG_SCAN] Thread: {:?}, Scan file ranges build ranges end, region_id: {}, partition: {}, index: {:?}, ranges: {}", std::thread::current().id(), stream_ctx.input.mapper.metadata().region_id, partition, @@ -211,7 +211,7 @@ pub(crate) fn scan_file_ranges( part_metrics.inc_build_reader_cost(build_cost); if read_type == "unordered_scan_files" { common_telemetry::debug!( - "Thread: {:?}, Scan file range, region_id: {}, partition: {}, file_id: {}, index: {:?}, build_cost: {:?}", + "[DEBUG_SCAN] Thread: {:?}, Scan file range, region_id: {}, partition: {}, file_id: {}, index: {:?}, build_cost: {:?}", std::thread::current().id(), stream_ctx.input.mapper.metadata().region_id, partition, diff --git a/src/mito2/src/read/unordered_scan.rs b/src/mito2/src/read/unordered_scan.rs index 2fb8c1d7e5..40d3fdfea8 100644 --- a/src/mito2/src/read/unordered_scan.rs +++ b/src/mito2/src/read/unordered_scan.rs @@ -134,7 +134,7 @@ impl UnorderedScan { let distinguish_range = self.properties.distinguish_partition_range(); common_telemetry::info!( - "Thread: {:?}, Unordered scan start, region_id: {}, partition: {}, num_ranges: {}, part_ranges: {:?}", + "[DEBUG_SCAN] Thread: {:?}, Unordered scan start, region_id: {}, partition: {}, num_ranges: {}, part_ranges: {:?}", std::thread::current().id(), stream_ctx.input.mapper.metadata().region_id, partition, @@ -150,7 +150,7 @@ impl UnorderedScan { // Scans each part. for (part_idx, part_range) in part_ranges.into_iter().enumerate() { common_telemetry::debug!( - "Thread: {:?}, Unordered scan range start {}/{}, region_id: {}, partition: {}, part_range: {:?}, range_meta: {:?}", + "[DEBUG_SCAN] Thread: {:?}, Unordered scan range start {}/{}, region_id: {}, partition: {}, part_range: {:?}, range_meta: {:?}", std::thread::current().id(), part_idx, ranges_len, @@ -213,7 +213,7 @@ impl UnorderedScan { let scan_cost = fetch_start.elapsed(); metrics.scan_cost += scan_cost; common_telemetry::debug!( - "Thread: {:?}, Unordered scan range end {}/{}, region_id: {}, partition: {}, part_range: {:?}, scan_cost: {:?}, yieid_cost: {:?}, num_rows: {}", + "[DEBUG_SCAN] Thread: {:?}, Unordered scan range end {}/{}, region_id: {}, partition: {}, part_range: {:?}, scan_cost: {:?}, yieid_cost: {:?}, num_rows: {}", std::thread::current().id(), part_idx, ranges_len,