From a32b80f1b05e2b328f3fce138a0be48327caaba2 Mon Sep 17 00:00:00 2001 From: dantengsky Date: Thu, 12 Dec 2024 08:58:45 +0800 Subject: [PATCH] refactor: tweak build_aggregate_partial (#17038) * refactor: tweak build_aggregate_partial * tweak cargo audit --- .cargo/audit.toml | 2 ++ src/query/service/src/pipelines/builders/builder_aggregate.rs | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/.cargo/audit.toml b/.cargo/audit.toml index 4334d3ec6c0a..8baefdb68c2a 100644 --- a/.cargo/audit.toml +++ b/.cargo/audit.toml @@ -51,4 +51,6 @@ ignore = [ "RUSTSEC-2024-0376", #rustls network-reachable panic in `Acceptor::accept` "RUSTSEC-2024-0399", + # `idna` accepts Punycode labels that do not produce any non-ASCII when decoded + "RUSTSEC-2024-0421", ] diff --git a/src/query/service/src/pipelines/builders/builder_aggregate.rs b/src/query/service/src/pipelines/builders/builder_aggregate.rs index 1ecf01b6b0f8..7904785a35e3 100644 --- a/src/query/service/src/pipelines/builders/builder_aggregate.rs +++ b/src/query/service/src/pipelines/builders/builder_aggregate.rs @@ -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()