Skip to content

Commit 7e7368d

Browse files
committed
fix
Signed-off-by: coldWater <forsaken628@gmail.com>
1 parent 289f956 commit 7e7368d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/query/service/src/pipelines/processors/transforms/sort/sort_collect.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ where
127127
let params = if no_spill {
128128
SortSpillParams {
129129
batch_rows: self.max_block_size,
130-
num_merge: merger.num_rows().div_ceil(self.max_block_size),
130+
num_merge: merger.num_rows().div_ceil(self.max_block_size).max(2),
131131
}
132132
} else {
133133
self.determine_params(merger.num_bytes(), merger.num_rows())
@@ -152,7 +152,7 @@ where
152152
let params = if no_spill {
153153
SortSpillParams {
154154
batch_rows: self.max_block_size,
155-
num_merge: num_rows.div_ceil(self.max_block_size),
155+
num_merge: num_rows.div_ceil(self.max_block_size).max(2),
156156
}
157157
} else {
158158
self.determine_params(num_bytes, num_rows)

0 commit comments

Comments
 (0)