chore: refine some unnecessary log (#410)

* remove some unnecessary informations in log

Signed-off-by: Ruihang Xia <waynestxia@gmail.com>

* further cleaning

Signed-off-by: Ruihang Xia <waynestxia@gmail.com>

Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
This commit is contained in:
Ruihang Xia
2022-11-07 16:36:27 +08:00
committed by GitHub
parent c2e1b0857c
commit ae147c2a74
4 changed files with 10 additions and 6 deletions

View File

@@ -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);

View File

@@ -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);
}
});

View File

@@ -252,7 +252,7 @@ impl<S: LogStore> EngineInner<S> {
Some(v) => v,
};
guard.update(RegionSlot::Ready(region.clone()));
info!("Storage engine open region {:?}", &region);
info!("Storage engine open region {}", region.id());
Ok(Some(region))
}
@@ -281,7 +281,7 @@ impl<S: LogStore> EngineInner<S> {
guard.update(RegionSlot::Ready(region.clone()));
info!("Storage engine create region {:?}", &region);
info!("Storage engine create region {}", region.id());
Ok(region)
}

View File

@@ -229,6 +229,11 @@ impl<S: LogStore> RegionImpl<S> {
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<Version>, RecoveredMetadataMap)> {