Minor changes

synnada-ai · Feb 21, 2024 · 93f5282 · 93f5282
1 parent 01eaf45
commit 93f5282
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/datafusion/physical-plan/src/joins/hash_join.rs b/datafusion/physical-plan/src/joins/hash_join.rs
@@ -445,7 +445,7 @@ impl HashJoinExec {
 
         // Determine execution mode by checking whether this join is pipeline
         // breaking. This happens when the left side is unbounded, or the right
-        // side is unbounded with `Right`, `Full` or `RightAnti` join types.
+        // side is unbounded with `Left`, `Full`, `LeftAnti` or `LeftSemi` join types.
         let pipeline_breaking = left.execution_mode().is_unbounded()
             || (right.execution_mode().is_unbounded()
                 && matches!(

diff --git a/datafusion/physical-plan/src/joins/nested_loop_join.rs b/datafusion/physical-plan/src/joins/nested_loop_join.rs
@@ -157,8 +157,7 @@ impl NestedLoopJoinExec {
             &[],
         );
 
-        // Get output partitioning, which is determined by the rule of
-        // `required_input_distribution`:
+        // Get output partitioning,
         let output_partitioning = if self.join_type == JoinType::Full {
             self.left.output_partitioning().clone()
         } else {