Skip to content

Commit 0bde63e

Browse files
committed
fix
1 parent 9dac217 commit 0bde63e

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

src/query/service/src/pipelines/processors/transforms/transform_partition_collect.rs

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -54,12 +54,8 @@ impl Exchange for HilbertPartitionExchange {
5454
fn partition(&self, data_block: DataBlock, n: usize) -> Result<Vec<DataBlock>> {
5555
// Extract the columns used for hash computation.
5656
let mut data_block = data_block.consume_convert_to_full();
57-
let range_ids = data_block
58-
.get_last_column()
59-
.as_number()
60-
.unwrap()
61-
.as_u_int64()
62-
.unwrap();
57+
let last = data_block.get_last_column().as_nullable().unwrap();
58+
let range_ids = last.column.as_number().unwrap().as_u_int64().unwrap();
6359

6460
// Scatter the data block to different partitions.
6561
let indices = range_ids

0 commit comments

Comments
 (0)