fix: cluster key use wrong index.

Author: youngsofun

src/query/sql/src/planner/expression_parser.rs

@@ -395,7 +395,30 @@ pub fn parse_cluster_keys(
     table_meta: Arc<dyn Table>,
     ast_exprs: Vec<AExpr>,
 ) -> Result<Vec<Expr>> {
-    let exprs = parse_ast_exprs(ctx, table_meta, ast_exprs)?;
+    let schema = table_meta.schema();
+    let (mut bind_context, metadata) = bind_table(table_meta)?;
+    let settings = ctx.get_settings();
+    let name_resolution_ctx = NameResolutionContext::try_from(settings.as_ref())?;
+    let mut type_checker = TypeChecker::try_create(
+        &mut bind_context,
+        ctx,
+        &name_resolution_ctx,
+        metadata,
+        &[],
+        false,
+    )?;
+
+    let exprs: Vec<Expr> = ast_exprs
+        .iter()
+        .map(|ast| {
+            let (scalar, _) = *type_checker.resolve(ast)?;
+            let expr = scalar
+                .as_expr()?
+                .project_column_ref(|col| schema.index_of(&col.column_name).unwrap());
+            Ok(expr)
+        })
+        .collect::<Result<_>>()?;
+
     let mut res = Vec::with_capacity(exprs.len());
     for expr in exprs {
         let inner_type = expr.data_type().remove_nullable();

src/query/storages/orc/src/copy_into_table/processors/decoder.rs

@@ -106,7 +106,7 @@ impl StripeDecoderForCopy {
                 display_name, id, ..
             } = expr
             {
-                if display_name.starts_with("#!") {
+                if let Some(display_name) = display_name.strip_prefix("#!") {
                     let typs = match field.data_type() {
                         DataType::Nullable(box DataType::Array(box DataType::Nullable(
                             box DataType::Tuple(v),
@@ -116,7 +116,7 @@ impl StripeDecoderForCopy {
                             unreachable!("expect value: array of tuple")
                         }
                     };
-                    let positions = display_name[2..]
+                    let positions = display_name
                         .split(',')
                         .map(|s| s.parse::<i32>().unwrap())
                         .collect::<Vec<i32>>();