Skip to content

Commit 0781aff

Browse files
committed
fix
1 parent b2d90d9 commit 0781aff

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,13 +60,13 @@ impl Exchange for HilbertPartitionExchange {
6060
.unwrap()
6161
.as_u_int64()
6262
.unwrap();
63-
data_block.pop_columns(1);
6463

6564
// Scatter the data block to different partitions.
6665
let indices = range_ids
6766
.iter()
6867
.map(|&id| (id % self.num_partitions as u64) as u16)
6968
.collect::<Vec<_>>();
69+
data_block.pop_columns(1);
7070
let scatter_indices =
7171
DataBlock::divide_indices_by_scatter_size(&indices, self.num_partitions);
7272
// Partition the data blocks to different processors.

0 commit comments

Comments
 (0)