WIP

Author: Dandandan

datafusion/physical-plan/src/joins/nested_loop_join.rs

@@ -1147,9 +1147,7 @@ impl NestedLoopJoinStream {
             left_data,
             metrics,
             buffered_left_data: None,
-            // Use at least 8 to avoid debug_assert in arrow-select's BatchCoalescer
-            // where Vec::reserve(n) for small n can allocate more capacity than n
-            output_buffer: Box::new(BatchCoalescer::new(schema, batch_size.max(8))),
+            output_buffer: Box::new(BatchCoalescer::new(schema, batch_size)),
             batch_size,
             current_right_batch: None,
             current_right_batch_matched: None,