alamb commented on issue #18474:
URL: https://github.com/apache/datafusion/issues/18474#issuecomment-3676938720
The stack trace is here
__rustc::rust_panic panicking.rs:895
std::panicking::panic_with_hook panicking.rs:859
std::panicking::panic_handler::{{closure}} panicking.rs:707
std::sys::backtrace::__rust_end_short_backtrace backtrace.rs:174
__rustc::rust_begin_unwind panicking.rs:698
core::panicking::panic_fmt panicking.rs:80
core::slice::index::slice_index_fail::do_panic::runtime panic.rs:173
core::slice::index::slice_index_fail panic.rs:178
[Inlined] <core::ops::range::Range<usize> as
core::slice::index::SliceIndex<[T]>>::index index.rs:438
[Inlined] core::slice::index::<impl core::ops::index::Index<I> for
[T]>::index index.rs:18
<alloc::vec::Vec<T,A> as core::ops::index::Index<I>>::index mod.rs:3628
datafusion_physical_plan::aggregates::group_values::multi_group_by::bytes_view::ByteViewGroupValueBuilder<B>::take_buffers_with_partial_last
bytes_view.rs:466
datafusion_physical_plan::aggregates::group_values::multi_group_by::bytes_view::ByteViewGroupValueBuilder<B>::take_n_inner
bytes_view.rs:399
<datafusion_physical_plan::aggregates::group_values::multi_group_by::bytes_view::ByteViewGroupValueBuilder<B>
as
datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupColumn>::take_n
bytes_view.rs:541
<datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupValuesColumn<_>
as
datafusion_physical_plan::aggregates::group_values::GroupValues>::emit::{{closure}}
mod.rs:1097
core::iter::adapters::map::map_fold::{{closure}} map.rs:88
<core::slice::iter::IterMut<T> as
core::iter::traits::iterator::Iterator>::fold macros.rs:255
<core::iter::adapters::map::Map<I,F> as
core::iter::traits::iterator::Iterator>::fold map.rs:128
core::iter::traits::iterator::Iterator::for_each iterator.rs:828
alloc::vec::Vec<T,A>::extend_trusted mod.rs:3825
<alloc::vec::Vec<T,A> as
alloc::vec::spec_extend::SpecExtend<T,I>>::spec_extend spec_extend.rs:26
<alloc::vec::Vec<T> as
alloc::vec::spec_from_iter_nested::SpecFromIterNested<T,I>>::from_iter
spec_from_iter_nested.rs:60
<alloc::vec::Vec<T> as
alloc::vec::spec_from_iter::SpecFromIter<T,I>>::from_iter spec_from_iter.rs:33
<alloc::vec::Vec<T> as
core::iter::traits::collect::FromIterator<T>>::from_iter mod.rs:3689
core::iter::traits::iterator::Iterator::collect iterator.rs:2028
<datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupValuesColumn<_>
as datafusion_physical_plan::aggregates::group_values::GroupValues>::emit
mod.rs:1098
datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream::emit
row_hash.rs:1032
datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream::emit_early_if_necessary
row_hash.rs:1142
<datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream
as futures_core::stream::Stream>::poll_next row_hash.rs:726
...
```
It looks to me like it is a bug in the early emission logic in
https://github.com/apache/datafusion/blob/2a08013af3ccf703bee202c959b40bb0d35bdea1/datafusion/physical-plan/src/aggregates/group_values/multi_group_by/bytes_view.rs#L331-L330
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
