diff --git a/src/catalog/src/local/manager.rs b/src/catalog/src/local/manager.rs index 2e76e3677a..f35f7b726c 100644 --- a/src/catalog/src/local/manager.rs +++ b/src/catalog/src/local/manager.rs @@ -7,7 +7,7 @@ use common_catalog::consts::{ SYSTEM_CATALOG_NAME, SYSTEM_CATALOG_TABLE_NAME, }; use common_recordbatch::RecordBatch; -use common_telemetry::{debug, info}; +use common_telemetry::info; use datatypes::prelude::ScalarVector; use datatypes::vectors::{BinaryVector, UInt8Vector}; use futures_util::lock::Mutex; @@ -183,7 +183,6 @@ impl LocalCatalogManager { info!("Registered schema: {:?}", s); } Entry::Table(t) => { - debug!("t: {:?}", t); self.open_and_register_table(&t).await?; info!("Registered table: {:?}", t); max_table_id = max_table_id.max(t.table_id); diff --git a/src/log-store/src/fs/file.rs b/src/log-store/src/fs/file.rs index fb6cfc7931..05dcc72659 100644 --- a/src/log-store/src/fs/file.rs +++ b/src/log-store/src/fs/file.rs @@ -9,8 +9,8 @@ use byteorder::ByteOrder; use byteorder::LittleEndian; use bytes::{Bytes, BytesMut}; use common_error::ext::BoxedError; -use common_telemetry::debug; use common_telemetry::logging::{error, info}; +use common_telemetry::{debug, trace}; use futures::Stream; use futures_util::StreamExt; use snafu::ResultExt; @@ -380,7 +380,7 @@ impl LogFile { } } } - debug!("Yield batch size: {}", batch.len()); + trace!("Yield batch size: {}", batch.len()); yield Ok(batch); } }); diff --git a/src/storage/src/engine.rs b/src/storage/src/engine.rs index b6e704c8a2..b9d05b9e24 100644 --- a/src/storage/src/engine.rs +++ b/src/storage/src/engine.rs @@ -252,7 +252,7 @@ impl EngineInner { Some(v) => v, }; guard.update(RegionSlot::Ready(region.clone())); - info!("Storage engine open region {:?}", ®ion); + info!("Storage engine open region {}", region.id()); Ok(Some(region)) } @@ -281,7 +281,7 @@ impl EngineInner { guard.update(RegionSlot::Ready(region.clone())); - info!("Storage engine create region {:?}", ®ion); + info!("Storage engine create region {}", region.id()); Ok(region) } diff --git a/src/storage/src/region.rs b/src/storage/src/region.rs index c05a46a002..d94d36f4b3 100644 --- a/src/storage/src/region.rs +++ b/src/storage/src/region.rs @@ -229,6 +229,11 @@ impl RegionImpl { Ok(Some(RegionImpl { inner })) } + /// Get ID of this region. + pub fn id(&self) -> RegionId { + self.inner.shared.id() + } + async fn recover_from_manifest( manifest: &RegionManifest, ) -> Result<(Option, RecoveredMetadataMap)> {