fix: try fix cluster aggregate hang

dqhl76 · dqhl76 · commit 2a8545cdbc65 · 2025-10-25T20:37:10.000+08:00
diff --git a/src/query/service/src/pipelines/processors/transforms/aggregator/build_partition_bucket.rs b/src/query/service/src/pipelines/processors/transforms/aggregator/build_partition_bucket.rs
@@ -94,7 +94,7 @@ pub fn build_partition_bucket(
         }
 
         pipeline.add_pipe(builder.finalize());
-        pipeline.try_resize(after_worker)?;
+        pipeline.resize(after_worker, true)?;
     } else {
         let input_nums = pipeline.output_len();
         let transform = TransformPartitionBucket::create(input_nums, params.clone())?;

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,7 @@ pub fn build_partition_bucket(`
`94`	`94`	`}`
`95`	`95`
`96`	`96`	`pipeline.add_pipe(builder.finalize());`
`97`		`- pipeline.try_resize(after_worker)?;`
	`97`	`+ pipeline.resize(after_worker, true)?;`
`98`	`98`	`} else {`
`99`	`99`	`let input_nums = pipeline.output_len();`
`100`	`100`	`let transform = TransformPartitionBucket::create(input_nums, params.clone())?;`