le instead of lt

Signed-off-by: Jay Zhan <[email protected]>
apache · Jan 22, 2025 · cee51c0 · cee51c0
1 parent 361727a
commit cee51c0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/datafusion/functions-aggregate/src/first_last.rs b/datafusion/functions-aggregate/src/first_last.rs
@@ -613,7 +613,7 @@ impl Accumulator for LastValueAccumulator {
                 orderings,
                 &get_sort_options(self.ordering_req.as_ref()),
             )?
-            .is_lt()
+            .is_le()
             {
                 self.update_with_new_row(&row);
             }
@@ -652,7 +652,7 @@ impl Accumulator for LastValueAccumulator {
             // version in the new data:
             if !self.is_set
                 || self.requirement_satisfied
-                || compare_rows(&self.orderings, last_ordering, &sort_options)?.is_lt()
+                || compare_rows(&self.orderings, last_ordering, &sort_options)?.is_le()
             {
                 // Update with last value in the state. Note that we should exclude the
                 // is_set flag from the state. Otherwise, we will end up with a state