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 index 721fd5088fdf..c75307d5b207 100644 --- 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 index d9b3b63b737f..710a79ce228b 100644 --- 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 {