Skip to content

Commit

Permalink
refactor: tweak build_aggregate_partial
Browse files Browse the repository at this point in the history
  • Loading branch information
dantengsky committed Dec 11, 2024
1 parent 62abe30 commit c47ac17
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ impl PipelineBuilder {
let method = DataBlock::choose_hash_method(&sample_block, group_cols, efficiently_memory)?;

// Need a global atomic to read the max current radix bits hint
let partial_agg_config = if !self.is_exchange_neighbor {
let partial_agg_config = if !self.ctx.get_cluster().is_empty() {
HashTableConfig::default().with_partial(true, max_threads as usize)
} else {
HashTableConfig::default()
Expand Down

0 comments on commit c47ac17

Please sign in to comment.