diff --git a/query/src/pipelines/new/processors/transforms/hash_join/hash_table.rs b/query/src/pipelines/new/processors/transforms/hash_join/hash_table.rs index 7df374608dc99..587297e6fa658 100644 --- a/query/src/pipelines/new/processors/transforms/hash_join/hash_table.rs +++ b/query/src/pipelines/new/processors/transforms/hash_join/hash_table.rs @@ -19,11 +19,9 @@ use std::sync::Arc; use std::sync::Mutex; use std::sync::RwLock; -use common_arrow::arrow::bitmap::Bitmap; use common_datablocks::DataBlock; use common_datablocks::HashMethod; use common_datablocks::HashMethodKind; -use common_datavalues::combine_validities; use common_datavalues::ColumnRef; use common_datavalues::DataSchemaRef; use common_datavalues::DataTypeImpl; @@ -197,12 +195,6 @@ impl HashJoinState for ChainHashTable { let hash_values = self.hash(&build_keys, input.num_rows())?; - let mut null_bitmap: Option = None; - for column in build_keys.iter() { - let (_, bitmap) = column.validity(); - null_bitmap = combine_validities(null_bitmap.as_ref(), bitmap); - } - self.row_space.push(input, hash_values)?; Ok(())