Skip to content

Commit 4d14675

Browse files
committed
update
1 parent db12a2b commit 4d14675

File tree

2 files changed

+0
-14
lines changed

2 files changed

+0
-14
lines changed

src/query/ee/src/hilbert_clustering/handler.rs

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -97,12 +97,6 @@ impl HilbertClusteringHandler for RealHilbertClusteringHandler {
9797
return Ok(None);
9898
}
9999

100-
let rows_per_block =
101-
block_thresholds.calc_rows_per_block(checker.total_size, checker.total_rows) as u64;
102-
let block_size = ctx.get_settings().get_max_block_size()?;
103-
ctx.get_settings()
104-
.set_max_block_size(rows_per_block.min(block_size))?;
105-
106100
let mut removed_statistics = Statistics::default();
107101
let mut removed_segment_indexes = Vec::with_capacity(target_segments.len());
108102
for (segment_loc, segment) in target_segments {

src/query/expression/src/utils/block_thresholds.rs

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -80,14 +80,6 @@ impl BlockThresholds {
8080

8181
let mut rows_per_block = total_rows.div_ceil(block_num_by_size);
8282
let max_bytes_per_block = match rows_per_block {
83-
v if v < self.max_rows_per_block / 10 => {
84-
// If block rows < 100_000, max_bytes_per_block set to 200M
85-
2 * self.max_bytes_per_block
86-
}
87-
v if v < self.max_rows_per_block / 2 => {
88-
// If block rows < 500_000, max_bytes_per_block set to 150M
89-
3 * self.max_bytes_per_block / 2
90-
}
9183
v if v < self.min_rows_per_block => {
9284
// If block rows < 800_000, max_bytes_per_block set to 125M
9385
5 * self.max_bytes_per_block / 4

0 commit comments

Comments
 (0)