log on wrong range index

Signed-off-by: Ruihang Xia <waynestxia@gmail.com>
This commit is contained in:
Ruihang Xia
2024-11-05 14:57:44 +08:00
parent 92b274a856
commit b8ac19c480

View File

@@ -479,6 +479,14 @@ impl PartSortStream {
// step to next proper PartitionRange
loop {
self.cur_part_idx += 1;
if self.cur_part_idx >= self.partition_ranges.len() {
common_telemetry::info!(
"[PartSortStream] Partition {} is finished its range with remaining {} rows",
self.partition,
next_sort_column.len()
);
break;
}
if next_sort_column.is_empty()
|| self.try_find_next_range(&next_sort_column)?.is_none()
{