From 32afd91f01fdafd73f4ff614fbe3b36d2310c6f2 Mon Sep 17 00:00:00 2001 From: evenyag Date: Wed, 4 Dec 2024 14:48:47 +0800 Subject: [PATCH] style: fix clippy --- src/query/src/optimizer/parallelize_scan.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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() };