test

Eventual-Inc · Feb 9, 2024 · c1d99d1 · c1d99d1
1 parent e5f5528
commit c1d99d1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/daft-plan/src/planner.rs b/src/daft-plan/src/planner.rs
@@ -497,7 +497,7 @@ pub fn plan(logical_plan: &LogicalPlan, cfg: Arc<DaftExecutionConfig>) -> DaftRe
                     } else {
                         let split_op = PhysicalPlan::FanoutByHash(FanoutByHash::new(
                             first_stage_agg.into(),
-                            num_input_partitions,
+                            1,
                             groupby.clone(),
                         ));
                         PhysicalPlan::ReduceMerge(ReduceMerge::new(split_op.into()))