This is an automated email from the ASF dual-hosted git repository. Rachelint pushed a commit to branch final-aggr-with-lazily-materialize-poc in repository https://gitbox.apache.org/repos/asf/datafusion.git
commit f800afb542388c0690290ef7cdccf96c8e947e0b Author: kamille <[email protected]> AuthorDate: Sun Jul 12 22:43:00 2026 +0800 test2. --- datafusion/physical-expr-common/src/binary_view_map.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/datafusion/physical-expr-common/src/binary_view_map.rs b/datafusion/physical-expr-common/src/binary_view_map.rs index 1bebb3f421..9de8798756 100644 --- a/datafusion/physical-expr-common/src/binary_view_map.rs +++ b/datafusion/physical-expr-common/src/binary_view_map.rs @@ -26,7 +26,7 @@ use arrow::datatypes::{BinaryViewType, ByteViewType, DataType, StringViewType}; use datafusion_common::hash_utils::RandomState; use datafusion_common::hash_utils::create_hashes; use datafusion_common::utils::proxy::{HashTableAllocExt, VecAllocExt}; -use std::fmt::Debug; +use std::{fmt::Debug, io::SeekFrom::Current}; use std::mem::size_of; use std::sync::Arc; @@ -396,7 +396,7 @@ where pub fn into_state(mut self) -> ArrayRef { // Flush any remaining in-progress buffer if !self.in_progress.is_empty() { - let flushed = std::mem::take(&mut self.in_progress); + let flushed = std::mem::replace(&mut self.in_progress, Vec::with_capacity(BYTE_VIEW_MAX_BLOCK_SIZE)); self.completed.push(Buffer::from_vec(flushed)); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
