From 8bf795d88c9f8f9b16539ac4408cce2bbc4a1260 Mon Sep 17 00:00:00 2001
From: evenyag <realevenyag@gmail.com>
Date: Tue, 5 Nov 2024 16:22:54 +0800
Subject: [PATCH] chore: more logs

---
 src/query/src/part_sort.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/query/src/part_sort.rs b/src/query/src/part_sort.rs
index 729bb6e3bb..3be644e904 100644
--- a/src/query/src/part_sort.rs
+++ b/src/query/src/part_sort.rs
@@ -479,6 +479,7 @@ impl PartSortStream {
                     let next_range_idx = self.try_find_next_range(&sort_column)?;
                     // `Some` means the current range is finished, split the batch into two parts and sort
                     if let Some(idx) = next_range_idx {
+                        common_telemetry::info!("[PartSortStream] Partition {} current range {} finished, range: {:?}, idx: {}", self.partition, self.cur_part_idx, self.partition_ranges[self.cur_part_idx], idx);
                         let this_range = batch.slice(0, idx);
                         let next_range = batch.slice(idx, batch.num_rows() - idx);
                         if this_range.num_rows() != 0 {