Fix MSRV error on 1.76.0

korowa · Aug 3, 2024 · 764cfd0 · 764cfd0
1 parent 5936b0f
commit 764cfd0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/datafusion/physical-expr-common/src/aggregate/groups_accumulator/prim_op.rs b/datafusion/physical-expr-common/src/aggregate/groups_accumulator/prim_op.rs
@@ -141,7 +141,7 @@ where
         values: &[ArrayRef],
         opt_filter: Option<&BooleanArray>,
     ) -> Result<Vec<ArrayRef>> {
-        let values = values[0].as_primitive::<T>();
+        let values = values[0].as_primitive::<T>().clone();
 
         // Initializing state with starting values
         let initial_state =
@@ -164,11 +164,11 @@ where
                 let (dt, values_buf, original_nulls) = values.clone().into_parts();
                 let nulls_buf =
                     NullBuffer::union(original_nulls.as_ref(), Some(&filter_nulls));
-                &PrimitiveArray::<T>::new(values_buf, nulls_buf).with_data_type(dt)
+                PrimitiveArray::<T>::new(values_buf, nulls_buf).with_data_type(dt)
             }
         };
 
-        let state_values = compute::binary_mut(initial_state, values, |mut x, y| {
+        let state_values = compute::binary_mut(initial_state, &values, |mut x, y| {
             (self.prim_fn)(&mut x, y);
             x
         });