fix: fix right join bug, issue 9018

lichuang · lichuang · commit d73a8f90a21f · 2022-12-03T19:41:52.000+08:00
diff --git a/src/query/service/src/pipelines/processors/transforms/hash_join/hash_join_state_impl.rs b/src/query/service/src/pipelines/processors/transforms/hash_join/hash_join_state_impl.rs
@@ -294,6 +294,9 @@ impl HashJoinState for JoinHashTable {
         }
 
         let rest_block = self.rest_block()?;
+        if rest_block.is_empty() {
+            return Ok(blocks.to_vec());
+        }
         let input_block = DataBlock::concat_blocks(&[blocks, &[rest_block]].concat())?;
 
         if unmatched_build_indexes.is_empty() && self.hash_join_desc.other_predicate.is_none() {

Original file line number	Diff line number	Diff line change
`@@ -294,6 +294,9 @@ impl HashJoinState for JoinHashTable {`
`294`	`294`	`}`
`295`	`295`
`296`	`296`	`let rest_block = self.rest_block()?;`
	`297`	`+ if rest_block.is_empty() {`
	`298`	`+ return Ok(blocks.to_vec());`
	`299`	`+ }`
`297`	`300`	`let input_block = DataBlock::concat_blocks(&[blocks, &[rest_block]].concat())?;`
`298`	`301`
`299`	`302`	`if unmatched_build_indexes.is_empty() && self.hash_join_desc.other_predicate.is_none() {`