diff --git a/Cargo.lock b/Cargo.lock index 9325fe41311a..adbf8d91ccc0 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -10139,9 +10139,9 @@ dependencies = [ [[package]] name = "lz4" -version = "1.26.0" +version = "1.24.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "958b4caa893816eea05507c20cfe47574a43d9a697138a7872990bba8a0ece68" +checksum = "7e9e2dd86df36ce760a60f6ff6ad526f7ba1f14ba0356f8254fb6905e6494df1" dependencies = [ "libc", "lz4-sys", @@ -10149,9 +10149,9 @@ dependencies = [ [[package]] name = "lz4-sys" -version = "1.10.0" +version = "1.9.4" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "109de74d5d2353660401699a4174a4ff23fcc649caf553df71933c7fb45ad868" +checksum = "57d27b317e207b10f69f5e75494119e391a96f48861ae870d1da6edac98ca900" dependencies = [ "cc", "libc", diff --git a/src/query/service/src/pipelines/builders/builder_aggregate.rs b/src/query/service/src/pipelines/builders/builder_aggregate.rs index 1ecf01b6b0f8..19a0134a96ba 100644 --- a/src/query/service/src/pipelines/builders/builder_aggregate.rs +++ b/src/query/service/src/pipelines/builders/builder_aggregate.rs @@ -136,6 +136,12 @@ impl PipelineBuilder { .cluster_with_partial(true, self.ctx.get_cluster().nodes.len()) }; + log::info!( + "[build_aggregate_partial] partial_agg_config: {:?}, {}", + partial_agg_config, + self.is_exchange_neighbor + ); + self.main_pipeline.add_transform(|input, output| { Ok(ProcessorPtr::create( match params.aggregate_functions.is_empty() {