File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/query/service/src/pipelines/processors/transforms/sort Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -127,7 +127,7 @@ where
127
127
let params = if no_spill {
128
128
SortSpillParams {
129
129
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 ) ,
131
131
}
132
132
} else {
133
133
self . determine_params ( merger. num_bytes ( ) , merger. num_rows ( ) )
@@ -152,7 +152,7 @@ where
152
152
let params = if no_spill {
153
153
SortSpillParams {
154
154
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 ) ,
156
156
}
157
157
} else {
158
158
self . determine_params ( num_bytes, num_rows)
You can’t perform that action at this time.
0 commit comments