Skip to content

Commit 2afd7aa

Browse files
committed
for test
1 parent 1e14bc8 commit 2afd7aa

File tree

2 files changed

+2
-5
lines changed

2 files changed

+2
-5
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -164,7 +164,7 @@ impl ReclusterChecker {
164164
});
165165

166166
if segment_should_recluster || !self.head_of_snapshot {
167-
self.total_bytes += segment.summary.uncompressed_byte_size as usize;
167+
self.total_bytes += segment.summary.compressed_byte_size as usize;
168168
self.segments.push((location.clone(), segment.clone()));
169169
}
170170

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

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -109,10 +109,7 @@ impl BlockThresholds {
109109
}
110110

111111
let block_num_by_rows = std::cmp::max(total_rows / self.min_rows_per_block, 1);
112-
let block_num_by_size = std::cmp::max(
113-
total_bytes / self.max_bytes_per_block,
114-
total_compressed / self.max_bytes_per_file,
115-
);
112+
let block_num_by_size = total_compressed / self.max_bytes_per_file;
116113
if block_num_by_rows >= block_num_by_size {
117114
return self.max_rows_per_block;
118115
}

0 commit comments

Comments
 (0)