We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 51d0a87 commit 85ed001Copy full SHA for 85ed001
datafusion/functions-aggregate/src/median.rs
@@ -450,8 +450,8 @@ impl<T: ArrowNumericType + Send> GroupsAccumulator for MedianGroupsAccumulator<T
450
.with_data_type(self.data_type.clone());
451
452
// `offsets` in `ListArray`, each row as a list element
453
- assert!(input_array.len() <= i32::MAX as usize);
454
- let offsets = (0..=input_array.len() as i32).collect::<Vec<_>>();
+ let offset_end = i32::try_from(input_array.len()).unwrap();
+ let offsets = (0..=offset_end).collect::<Vec<_>>();
455
// Safety: all checks in `OffsetBuffer::new` are ensured to pass
456
let offsets = unsafe { OffsetBuffer::new_unchecked(ScalarBuffer::from(offsets)) };
457
0 commit comments