Skip to content

Commit f6dcfde

Browse files
committed
fix: forget return
1 parent 47dd6fc commit f6dcfde

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/query/service/src/pipelines/processors/transforms/aggregator/new_aggregate/new_aggregate_spiller.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -205,6 +205,7 @@ impl SharedPartitionStreamInner {
205205
pending_blocks.push((id, block));
206206
}
207207
}
208+
return pending_blocks;
208209
}
209210
vec![]
210211
}

0 commit comments

Comments
 (0)