Merge pull request #14 from probably-nothing-labs/amey/multi-stage-ag…

…gregates Quickfix for full aggregates
probably-nothing-labs · Aug 8, 2024 · a8a401c · a8a401c
2 parents ee54420 + 6b4a10d
commit a8a401c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/crates/core/src/planner/streaming_window.rs b/crates/core/src/planner/streaming_window.rs
@@ -128,7 +128,7 @@ impl ExtensionPlanner for StreamingWindowPlanner {
                 };
 
                 let initial_aggr = Arc::new(FranzStreamingWindowExec::try_new(
-                    AggregateMode::Partial,
+                    AggregateMode::Single,
                     groups.clone(),
                     aggregates.clone(),
                     filters.clone(),