File tree Expand file tree Collapse file tree 2 files changed +2
-1
lines changed
src/query/service/src/pipelines Expand file tree Collapse file tree 2 files changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -829,7 +829,6 @@ impl PipelineBuilder {
829829 || join. join_type == JoinType :: Single )
830830 && join. non_equi_conditions . is_empty ( )
831831 {
832- // self.main_pipeline.resize(1)?;
833832 self . main_pipeline . add_transform ( |input, output| {
834833 let transform = TransformLeftJoin :: try_create (
835834 input,
Original file line number Diff line number Diff line change @@ -53,6 +53,8 @@ impl Compactor for LeftJoinCompactor {
5353
5454 // `compact_final` is called when all the blocks are pushed
5555 fn compact_final ( & self , blocks : & [ DataBlock ] ) -> Result < Vec < DataBlock > > {
56+ // If upstream data block is small, all blocks will be in rest blocks
57+ // So compact partial won't be triggered, we still need to compact final here.
5658 self . hash_join_state . left_join_blocks ( blocks)
5759 }
5860}
You can’t perform that action at this time.
0 commit comments