This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git


The following commit(s) were added to refs/heads/main by this push:
     new efcc2164ce Minor: Remove unneccessary vec! in SortMergeJoinStream 
initialization (#18430)
efcc2164ce is described below

commit efcc2164cebceda2d26a61f87a80374b28924f77
Author: mwish <[email protected]>
AuthorDate: Sun Nov 2 12:22:11 2025 +0800

    Minor: Remove unneccessary vec! in SortMergeJoinStream initialization 
(#18430)
    
    ## Which issue does this PR close?
    
    <!--
    We generally require a GitHub issue to be filed for all bug fixes and
    enhancements and this helps us generate change logs for our releases.
    You can link an issue to this PR using the GitHub syntax. For example
    `Closes #123` indicates that this PR will close issue #123.
    -->
    
    Remove a unnecessary vec allocation in SortMergeJoinStream
    initialization
    
    ## Rationale for this change
    
    Remove a unnecessary vec allocation in SortMergeJoinStream
    initialization
    
    ## What changes are included in this PR?
    
    Remove a unnecessary vec allocation in SortMergeJoinStream
    initialization
    
    ## Are these changes tested?
    
    Covered by existing
    
    ## Are there any user-facing changes?
    
    No
---
 datafusion/physical-plan/src/joins/sort_merge_join/stream.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/datafusion/physical-plan/src/joins/sort_merge_join/stream.rs 
b/datafusion/physical-plan/src/joins/sort_merge_join/stream.rs
index 5a2e3669ab..7639e4fc55 100644
--- a/datafusion/physical-plan/src/joins/sort_merge_join/stream.rs
+++ b/datafusion/physical-plan/src/joins/sort_merge_join/stream.rs
@@ -604,7 +604,7 @@ impl Stream for SortMergeJoinStream {
                                             // Append filtered batch to the 
output buffer
                                             self.output = concat_batches(
                                                 &self.schema(),
-                                                vec![&self.output, 
&out_filtered_batch],
+                                                [&self.output, 
&out_filtered_batch],
                                             )?;
 
                                             // Send to output if the output 
buffer surpassed the `batch_size`


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to