From b63a6313884fb47423b11fd91514e1f397416ff0 Mon Sep 17 00:00:00 2001 From: berkaysynnada Date: Wed, 30 Oct 2024 16:21:27 +0300 Subject: [PATCH] Update merge.rs --- datafusion/physical-plan/src/sorts/merge.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/datafusion/physical-plan/src/sorts/merge.rs b/datafusion/physical-plan/src/sorts/merge.rs index 061d28fd208a..54ed1242010d 100644 --- a/datafusion/physical-plan/src/sorts/merge.rs +++ b/datafusion/physical-plan/src/sorts/merge.rs @@ -445,8 +445,8 @@ impl SortPreservingMergeStream { 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); }