rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-04 04:12:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: log label

Browse Source
This commit is contained in:
evenyag
2024-11-08 01:08:02 +08:00
parent 4f446b95d8
commit 9a6c7aa4d6
3 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/mito2/src/read/scan_region.rs
View File

@@ -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(),

6
src/mito2/src/read/scan_util.rs
View File

@@ -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,

6
src/mito2/src/read/unordered_scan.rs
View File

@@ -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,