diff --git a/src/query/src/optimizer/parallelize_scan.rs b/src/query/src/optimizer/parallelize_scan.rs index 03aadafce6..f87d6f19d7 100644 --- a/src/query/src/optimizer/parallelize_scan.rs +++ b/src/query/src/optimizer/parallelize_scan.rs @@ -131,7 +131,7 @@ impl ParallelizeScan { let total_rows = ranges.iter().map(|range| range.num_rows).sum::(); // Computes the partition num by the max row number. This eliminates the unbalance of the partitions. let balanced_partition_num = if max_rows > 0 { - (total_rows + max_rows - 1) / max_rows + total_rows.div_ceil(max_rows) } else { ranges.len() };