Skip to content

Commit 8784acc

Browse files
committed
fix
1 parent 62de97e commit 8784acc

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/query/storages/fuse/src/operations/mutation/mutator/recluster_mutator.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ impl ReclusterMutator {
109109
.summary
110110
.uncompressed_byte_size
111111
.div_ceil(snapshot.summary.block_count) as usize,
112-
block_thresholds.max_bytes_per_block / 2,
112+
block_thresholds.min_bytes_per_block,
113113
);
114114
Ok(Self {
115115
ctx,
@@ -206,7 +206,7 @@ impl ReclusterMutator {
206206
settings.get_max_memory_usage()? - GLOBAL_MEM_STAT.get_memory_usage() as u64;
207207
let memory_threshold = settings
208208
.get_recluster_block_size()?
209-
.min(avail_memory_usage * 30 / 100) as usize;
209+
.min(avail_memory_usage * 50 / 100) as usize;
210210
// specify a rather small value, so that `recluster_block_size` might be tuned to lower value.
211211
let max_blocks_num = (memory_threshold / self.average_size).max(2) * self.max_tasks;
212212
let block_per_seg = self.block_thresholds.block_per_segment;

0 commit comments

Comments
 (0)