Skip to content

Commit a32b80f

Browse files
authored
refactor: tweak build_aggregate_partial (#17038)
* refactor: tweak build_aggregate_partial * tweak cargo audit
1 parent 62abe30 commit a32b80f

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

.cargo/audit.toml

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,4 +51,6 @@ ignore = [
5151
"RUSTSEC-2024-0376",
5252
#rustls network-reachable panic in `Acceptor::accept`
5353
"RUSTSEC-2024-0399",
54+
# `idna` accepts Punycode labels that do not produce any non-ASCII when decoded
55+
"RUSTSEC-2024-0421",
5456
]

src/query/service/src/pipelines/builders/builder_aggregate.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ impl PipelineBuilder {
129129
let method = DataBlock::choose_hash_method(&sample_block, group_cols, efficiently_memory)?;
130130

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

0 commit comments

Comments
 (0)