File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
datafusion/functions-aggregate/src Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -397,7 +397,7 @@ impl<T: ArrowNumericType + Send> GroupsAccumulator for MedianGroupsAccumulator<T
397397
398398 // Build the result list array
399399 let result_list_array = ListArray :: new (
400- Arc :: new ( Field :: new_list_field ( self . data_type . clone ( ) , false ) ) ,
400+ Arc :: new ( Field :: new_list_field ( self . data_type . clone ( ) , true ) ) ,
401401 offsets,
402402 Arc :: new ( group_values_array) ,
403403 None ,
@@ -449,7 +449,7 @@ impl<T: ArrowNumericType + Send> GroupsAccumulator for MedianGroupsAccumulator<T
449449 let nulls = filtered_null_mask ( opt_filter, input_array) ;
450450
451451 let converted_list_array = ListArray :: new (
452- Arc :: new ( Field :: new_list_field ( self . data_type . clone ( ) , false ) ) ,
452+ Arc :: new ( Field :: new_list_field ( self . data_type . clone ( ) , true ) ) ,
453453 offsets,
454454 Arc :: new ( values) ,
455455 nulls,
You can’t perform that action at this time.
0 commit comments