diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs index 838339c67440..438d9818475d 100644 --- 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]), ) }