add log

databendlabs · Oct 23, 2024 · 9097b7c · 9097b7c
1 parent b783e2b
commit 9097b7c
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/query/storages/fuse/src/operations/append.rs b/src/query/storages/fuse/src/operations/append.rs
@@ -34,6 +34,7 @@ use databend_common_sql::evaluator::BlockOperator;
 use databend_common_sql::evaluator::CompoundBlockOperator;
 use databend_common_sql::executor::physical_plans::MutationKind;
 use databend_storages_common_table_meta::meta::TableMetaTimestamps;
+use log::info;
 
 use crate::operations::common::TransformSerializeBlock;
 use crate::statistics::ClusterStatsGenerator;
@@ -53,7 +54,13 @@ impl FuseTable {
         let cluster_stats_gen =
             self.cluster_gen_for_append(ctx.clone(), pipeline, block_thresholds, Some(schema))?;
         let max_io_requests = ctx.get_settings().get_max_storage_io_requests()? as usize;
+        let before_len = pipeline.output_len();
         pipeline.try_resize(max_io_requests)?;
+        let after_len = pipeline.output_len();
+        info!(
+            "append data, before len: {}, after len: {}",
+            before_len, after_len,
+        );
         pipeline.add_transform(|input, output| {
             let proc = TransformSerializeBlock::try_create(
                 ctx.clone(),