File tree Expand file tree Collapse file tree 1 file changed +5
-11
lines changed
src/query/service/src/pipelines/processors/transforms Expand file tree Collapse file tree 1 file changed +5
-11
lines changed Original file line number Diff line number Diff line change @@ -227,11 +227,6 @@ impl Processor for TransformHilbertPartitionCollect {
227
227
return Ok ( Event :: NeedConsume ) ;
228
228
}
229
229
230
- if self . need_spill ( ) {
231
- self . state = State :: Spill ;
232
- return Ok ( Event :: Async ) ;
233
- }
234
-
235
230
if let Some ( data_block) = self . output_data_blocks . pop ( ) {
236
231
self . output . push_data ( Ok ( data_block) ) ;
237
232
return Ok ( Event :: NeedConsume ) ;
@@ -256,14 +251,13 @@ impl Processor for TransformHilbertPartitionCollect {
256
251
return Ok ( Event :: Finished ) ;
257
252
}
258
253
254
+ if self . need_spill ( ) {
255
+ self . state = State :: Spill ;
256
+ return Ok ( Event :: Async ) ;
257
+ }
258
+
259
259
if self . input . has_data ( ) {
260
260
self . collect_data_block ( ) ?;
261
-
262
- if self . need_spill ( ) {
263
- self . state = State :: Spill ;
264
- return Ok ( Event :: Async ) ;
265
- }
266
-
267
261
if !self . immediate_output_blocks . is_empty ( ) {
268
262
self . state = State :: Flush ;
269
263
return Ok ( Event :: Async ) ;
You can’t perform that action at this time.
0 commit comments