fix

apache · Dec 26, 2024 · e309d28 · e309d28
1 parent 6b39a0c
commit e309d28
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/be/src/vec/common/sort/sorter.cpp b/be/src/vec/common/sort/sorter.cpp
@@ -120,8 +120,8 @@ Status MergeSorterState::_merge_sort_read_impl(int batch_size, doris::vectorized
             merged_rows += current_rows;
         }
 
-        if (!current->impl->is_last(current_rows)) {
-            priority_queue_.next(current_rows);
+        if (!current->impl->is_last(current_rows + step)) {
+            priority_queue_.next(current_rows + step);
         } else {
             priority_queue_.remove_top();
         }