File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
src/query/service/src/interpreters Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -249,9 +249,10 @@ impl ReclusterTableInterpreter {
249249 let block_thresholds = tbl. get_block_thresholds ( ) ;
250250 let total_bytes = recluster_info. removed_statistics . uncompressed_byte_size as usize ;
251251 let total_rows = recluster_info. removed_statistics . row_count as usize ;
252- let rows_per_block = block_thresholds. calc_rows_per_block ( total_bytes, total_rows) ;
253252 let block_size = settings. get_max_block_size ( ) ?;
254- settings. set_max_block_size ( std:: cmp:: min ( rows_per_block as u64 , block_size) ) ?;
253+ let rows_per_block = block_thresholds
254+ . calc_rows_per_block ( total_bytes, total_rows)
255+ . max ( block_size as usize ) ;
255256 let total_partitions = std:: cmp:: max ( total_rows / rows_per_block, 1 ) ;
256257
257258 let ast_exprs = tbl. resolve_cluster_keys ( self . ctx . clone ( ) ) . unwrap ( ) ;
You can’t perform that action at this time.
0 commit comments