From 94f08ff542bf1161b21fdc986ada52fd12f3905f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Berkay=20=C5=9Eahin?=
 <124376117+berkaysynnada@users.noreply.github.com>
Date: Tue, 24 Dec 2024 15:58:39 +0300
Subject: [PATCH] Update sort_merge_join.rs (#13894)

---
 datafusion/physical-plan/src/joins/sort_merge_join.rs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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]),
         )
     }