We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 481ec2e commit 364cc4bCopy full SHA for 364cc4b
src/query/service/src/interpreters/interpreter_table_recluster.rs
@@ -249,7 +249,7 @@ impl ReclusterTableInterpreter {
249
let block_thresholds = tbl.get_block_thresholds();
250
let total_bytes = recluster_info.removed_statistics.uncompressed_byte_size as usize;
251
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);
+ let rows_per_block = block_thresholds.calc_rows_per_block(total_bytes, total_rows).max(65536);
253
let total_partitions = std::cmp::max(total_rows / rows_per_block, 1);
254
255
let ast_exprs = tbl.resolve_cluster_keys(self.ctx.clone()).unwrap();
0 commit comments