chore(query): fix TransformWindowPartitionScatter

databendlabs · Sep 18, 2024 · d431163 · d431163
1 parent 3837ef9
commit d431163
Showing 1 changed file with 1 addition and 20 deletions.
diff --git a/...rc/pipelines/processors/transforms/window/partition/transform_window_partition_scatter.rs b/...rc/pipelines/processors/transforms/window/partition/transform_window_partition_scatter.rs
@@ -90,26 +90,7 @@ impl Processor for TransformWindowPartitionScatter {
 
     fn event(&mut self) -> Result<Event> {
         if !self.is_initialized {
-            let mut all_output_finished = true;
-            let mut all_output_can_push = true;
-            for (index, output_port) in self.output_ports.iter().enumerate() {
-                if output_port.is_finished() {
-                    self.output_data_blocks[index].clear();
-                    continue;
-                }
-                all_output_finished = false;
-
-                if !output_port.can_push() {
-                    all_output_can_push = false;
-                    continue;
-                }
-            }
-            if all_output_finished {
-                return self.finish();
-            }
-            if all_output_can_push {
-                self.is_initialized = true;
-            }
+            self.is_initialized = true;
             self.input_port.set_need_data();
             return Ok(Event::NeedData);
         }