Skip to content

Commit

Permalink
Update merge.rs
Browse files Browse the repository at this point in the history
  • Loading branch information
berkaysynnada committed Oct 30, 2024
1 parent f68fa9b commit b63a631
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions datafusion/physical-plan/src/sorts/merge.rs
Original file line number Diff line number Diff line change
Expand Up @@ -445,8 +445,8 @@ impl<C: CursorValues> SortPreservingMergeStream<C> {
self.update_winner(cmp_node, winner, challenger);
}
} else if challenger < *winner {
// If the winner doesn't surivie in the final match, it means the value has changed,
// The polls count are outdated (because the value advanced) but not yet cleanup at this point.
// If the winner doesn't survive in the final match, it means the value has changed.
// The polls count are outdated (because the value advanced) but not yet cleaned-up at this point.
// Given the value is equal, we choose the smaller index if the value is the same.
self.update_winner(cmp_node, winner, challenger);
}
Expand Down

0 comments on commit b63a631

Please sign in to comment.