diff --git a/src/mito2/src/sst/index/intermediate.rs b/src/mito2/src/sst/index/intermediate.rs
index 0c0497ad65..38b1f81cbc 100644
--- a/src/mito2/src/sst/index/intermediate.rs
+++ b/src/mito2/src/sst/index/intermediate.rs
@@ -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);
 
diff --git a/src/sst-convert/src/converter.rs b/src/sst-convert/src/converter.rs
index 4f71fe6df4..b71411b0ec 100644
--- a/src/sst-convert/src/converter.rs
+++ b/src/sst-convert/src/converter.rs
@@ -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)
     }