mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2025-12-22 22:20:02 +00:00
chore: add more logs
This commit is contained in:
@@ -49,6 +49,11 @@ impl IntermediateManager {
|
||||
/// Create a new `IntermediateManager` with the given root path.
|
||||
/// It will clean up all garbage intermediate files from previous runs.
|
||||
pub async fn init_fs(aux_path: impl AsRef<str>) -> Result<Self> {
|
||||
common_telemetry::info!(
|
||||
"Initializing intermediate manager, aux_path: {}",
|
||||
aux_path.as_ref()
|
||||
);
|
||||
|
||||
let store = new_fs_cache_store(&normalize_dir(aux_path.as_ref())).await?;
|
||||
let store = InstrumentedStore::new(store);
|
||||
|
||||
|
||||
@@ -80,11 +80,16 @@ pub struct SstConverter {
|
||||
impl SstConverter {
|
||||
/// Converts a list of input to a list of outputs.
|
||||
pub async fn convert(&mut self, input: &[InputFile]) -> Result<Vec<OutputSst>> {
|
||||
common_telemetry::info!("Converting input {} files", input.len());
|
||||
|
||||
let mut outputs = Vec::with_capacity(input.len());
|
||||
for file in input {
|
||||
let output = self.convert_one(file).await?;
|
||||
outputs.push(output);
|
||||
}
|
||||
|
||||
common_telemetry::info!("Converted {} files", outputs.len());
|
||||
|
||||
Ok(outputs)
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user