Update sort_merge_join.rs (#13894)

berkaysynnada · web-flow · commit 94f08ff542bf · 2024-12-24T07:58:39.000-05:00
diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs
@@ -304,11 +304,10 @@ impl SortMergeJoinExec {
         let output_partitioning =
             symmetric_join_output_partitioning(left, right, &join_type);
 
-        // TODO: Emission type may be incremental if the input is sorted
         PlanProperties::new(
             eq_properties,
             output_partitioning,
-            EmissionType::Final,
+            EmissionType::Incremental,
             boundedness_from_children([left, right]),
         )
     }

Original file line number	Diff line number	Diff line change
`@@ -304,11 +304,10 @@ impl SortMergeJoinExec {`
`304`	`304`	`let output_partitioning =`
`305`	`305`	`symmetric_join_output_partitioning(left, right, &join_type);`
`306`	`306`
`307`		`- // TODO: Emission type may be incremental if the input is sorted`
`308`	`307`	`PlanProperties::new(`
`309`	`308`	`eq_properties,`
`310`	`309`	`output_partitioning,`
`311`		`- EmissionType::Final,`
	`310`	`+ EmissionType::Incremental,`
`312`	`311`	`boundedness_from_children([left, right]),`
`313`	`312`	`)`
`314`	`313`	`}`