fix: remove trivial column in block operator (#10940)

Author: xudong963

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

@@ -25,6 +25,7 @@ use common_expression::DataBlock;
 use common_expression::DataSchemaRef;
 use common_expression::FunctionContext;
 use common_expression::HashMethodKind;
+use common_expression::RemoteExpr;
 use common_expression::SortColumnDescription;
 use common_functions::aggregates::AggregateFunctionFactory;
 use common_functions::aggregates::AggregateFunctionRef;
@@ -382,6 +383,12 @@ impl PipelineBuilder {
         let exprs = eval_scalar
             .exprs
             .iter()
+            .filter(|(scalar, idx)| {
+                if let RemoteExpr::ColumnRef { id, .. } = scalar {
+                    return idx != id;
+                }
+                true
+            })
             .map(|(scalar, _)| scalar.as_expr(&BUILTIN_FUNCTIONS))
             .collect::<Vec<_>>();
 

src/query/sql/src/executor/physical_plan.rs

@@ -133,6 +133,11 @@ impl EvalScalar {
         let input_schema = self.input.output_schema()?;
         let mut fields = input_schema.fields().clone();
         for (expr, index) in self.exprs.iter() {
+            if let RemoteExpr::ColumnRef { id, .. } = expr {
+                if index == id {
+                    continue;
+                }
+            }
             let name = index.to_string();
             let data_type = expr.as_expr(&BUILTIN_FUNCTIONS).data_type().clone();
             fields.push(DataField::new(&name, data_type));