diff --git a/datafusion/src/physical_plan/hash_aggregate.rs b/datafusion/src/physical_plan/hash_aggregate.rs index 0a822dc898af..c9d268619cad 100644 --- a/datafusion/src/physical_plan/hash_aggregate.rs +++ b/datafusion/src/physical_plan/hash_aggregate.rs @@ -1164,7 +1164,7 @@ fn create_group_by_value(col: &ArrayRef, row: usize) -> Result { } DataType::LargeUtf8 => { let array = col.as_any().downcast_ref::().unwrap(); - Ok(GroupByScalar::Utf8(Box::new(array.value(row).into()))) + Ok(GroupByScalar::LargeUtf8(Box::new(array.value(row).into()))) } DataType::Boolean => { let array = col.as_any().downcast_ref::().unwrap();