Skip to content

Commit 4151360

Browse files
committed
fix
1 parent 364cc4b commit 4151360

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/query/service/src/interpreters/interpreter_table_recluster.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,7 +249,9 @@ 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).max(65536);
252+
let rows_per_block = block_thresholds
253+
.calc_rows_per_block(total_bytes, total_rows)
254+
.max(65536);
253255
let total_partitions = std::cmp::max(total_rows / rows_per_block, 1);
254256

255257
let ast_exprs = tbl.resolve_cluster_keys(self.ctx.clone()).unwrap();

0 commit comments

Comments
 (0)