Skip to content

Commit f8a96c8

Browse files
committed
fix
1 parent 23ab909 commit f8a96c8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -308,7 +308,9 @@ impl Processor for TransformHilbertPartitionCollect {
308308
State::Spill => self.buffer.spill().await?,
309309
State::Restore => {
310310
self.restored_data_blocks = self.buffer.restore().await?;
311-
self.state = State::Concat;
311+
if !self.restored_data_blocks.is_empty() {
312+
self.state = State::Concat;
313+
}
312314
}
313315
_ => unreachable!(),
314316
}

0 commit comments

Comments
 (0)