remove builder.contain_sink_processor

Author: SkyFan2002

src/query/service/src/physical_plans/physical_aggregate_partial.rs

@@ -167,7 +167,6 @@ impl IPhysicalPlan for AggregatePartial {
     }
 
     fn build_pipeline2(&self, builder: &mut PipelineBuilder) -> Result<()> {
-        builder.contain_sink_processor = true;
         self.input.build_pipeline(builder)?;
 
         let max_block_size = builder.settings.get_max_block_size()?;

src/query/service/src/pipelines/pipeline_builder.rs

@@ -59,8 +59,6 @@ pub struct PipelineBuilder {
 
     pub r_cte_scan_interpreters: Vec<CreateTableInterpreter>,
     pub(crate) is_exchange_stack: Vec<bool>,
-
-    pub contain_sink_processor: bool,
 }
 
 impl PipelineBuilder {
@@ -80,7 +78,6 @@ impl PipelineBuilder {
             join_state: None,
             hash_join_states: HashMap::new(),
             r_cte_scan_interpreters: vec![],
-            contain_sink_processor: false,
             is_exchange_stack: vec![],
         }
     }