add logs

databendlabs · Jan 13, 2024 · 33c0c4d · 33c0c4d
1 parent ed364da
commit 33c0c4d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/src/query/service/src/pipelines/processors/transforms/hash_join/hash_join_probe_state.rs b/src/query/service/src/pipelines/processors/transforms/hash_join/hash_join_probe_state.rs
@@ -491,10 +491,15 @@ impl HashJoinProbeState {
         let all_matched_blocks = block_info_index.gather_matched_all_blocks(matched);
         // generate chunks
         let mut tasks = block_info_index.chunk_offsets(&partial_unmodified, chunks_offsets);
+        info!("partial unmodified blocks num: {}", tasks.len());
         for prefix in all_matched_blocks {
             // deleted block
             tasks.push((Vec::new(), prefix));
         }
+        info!(
+            "partial unmodified blocks and matched whole blocks num: {}",
+            tasks.len()
+        );
         *self.final_merge_into_partial_unmodified_scan_tasks.write() = tasks.into();
         Ok(())
     }

diff --git a/src/query/storages/fuse/src/operations/merge_into/mutator/matched_mutator.rs b/src/query/storages/fuse/src/operations/merge_into/mutator/matched_mutator.rs
@@ -268,7 +268,7 @@ impl MatchedAggregator {
                 let segment_info = segment_infos.get(&item.0).unwrap();
                 let block_idx = segment_info.blocks.len() - block_idx - 1;
                 info!(
-                    "merge into apply: segment_idx:{},blk_idx:{}",
+                    "target_build_optimization, merge into apply: segment_idx:{},blk_idx:{}",
                     segment_idx, block_idx
                 );
                 mutation_logs.push(MutationLogEntry::DeletedBlock {