1 parent 74315c2 commit a0008f3Copy full SHA for a0008f3
1 file changed
crates/core/src/udaf.rs
@@ -304,8 +304,9 @@ impl AggregateUDFImpl for PythonFunctionAggregateUDF {
304
305
fn accumulator(&self, acc_args: AccumulatorArgs) -> Result<Box<dyn Accumulator>> {
306
// The Python accumulator cannot see the flag, so it would count every
307
- // row. A plan the optimizer rewrote to group by the distinct values
308
- // arrives here without it and still runs.
+ // row. A query with a single DISTINCT argument is rewritten by the
+ // optimizer to group by those values; it arrives here without the
309
+ // flag and still runs.
310
if acc_args.is_distinct {
311
return datafusion::common::not_impl_err!(
312
"DISTINCT is not supported for the Python aggregate UDF {}",
0 commit comments