From a66909a56236f488a238912f514550407f6eb454 Mon Sep 17 00:00:00 2001
From: evenyag <realevenyag@gmail.com>
Date: Wed, 6 Nov 2024 16:29:18 +0800
Subject: [PATCH] chore: fix compile

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

diff --git a/src/query/src/part_sort.rs b/src/query/src/part_sort.rs
index 313f7d454a..e88d14f3cc 100644
--- a/src/query/src/part_sort.rs
+++ b/src/query/src/part_sort.rs
@@ -400,7 +400,7 @@ impl PartSortStream {
             self.region_id,
             self.partition,
             self.cur_part_idx,
-            self.buffer.iter().map(|b| b.len()).sum::<usize>(),
+            self.buffer.iter().map(|b| b.num_rows()).sum::<usize>(),
         );
 
         let mut sort_columns = Vec::with_capacity(self.buffer.len());