Skip to content

Commit 810e119

Browse files
committed
fix
1 parent dbc929e commit 810e119

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -169,9 +169,8 @@ impl TransformHilbertPartitionCollect {
169169
.and_then(WindowPartitionMeta::downcast_from)
170170
{
171171
for (partition_id, data_block) in meta.partitioned_data.into_iter() {
172-
let new_id = self.partition_id[partition_id];
173-
log::warn!("collect partition id {}, new_id {}", partition_id, new_id);
174-
self.buffer.add_data_block(new_id, data_block);
172+
let partition_id = self.partition_id[partition_id];
173+
self.buffer.add_data_block(partition_id, data_block);
175174
}
176175
}
177176
Ok(())

0 commit comments

Comments
 (0)