cleanup after emit (#15834)

jayzhan211 · web-flow · commit 377483f56679 · 2025-04-24T17:58:07.000+08:00
diff --git a/datafusion/physical-plan/src/aggregates/group_values/row.rs b/datafusion/physical-plan/src/aggregates/group_values/row.rs
@@ -202,6 +202,7 @@ impl GroupValues for GroupValuesRows {
             EmitTo::All => {
                 let output = self.row_converter.convert_rows(&group_values)?;
                 group_values.clear();
+                self.map.clear();
                 output
             }
             EmitTo::First(n) => {

Original file line number	Diff line number	Diff line change
`@@ -202,6 +202,7 @@ impl GroupValues for GroupValuesRows {`
`202`	`202`	`EmitTo::All => {`
`203`	`203`	`let output = self.row_converter.convert_rows(&group_values)?;`
`204`	`204`	`group_values.clear();`
	`205`	`+ self.map.clear();`
`205`	`206`	`output`
`206`	`207`	`}`
`207`	`208`	`EmitTo::First(n) => {`