File tree 1 file changed +9
-9
lines changed
src/query/service/src/interpreters
1 file changed +9
-9
lines changed Original file line number Diff line number Diff line change @@ -349,19 +349,19 @@ impl MergeIntoInterpreter {
349
349
350
350
let ( scalar_expr, _) = * type_checker. resolve ( ast_expr) . await ?;
351
351
352
- match & scalar_expr {
352
+ let left_most_expr = match & scalar_expr {
353
353
ScalarExpr :: FunctionCall ( f) if f. func_name == "tuple" && !f. arguments . is_empty ( ) => {
354
- let left_most_expr = f. arguments [ 0 ] . clone ( ) ;
355
- let projected = left_most_expr. try_project_column_binding ( |binding| {
356
- column_map. get ( & binding. column_name ) . cloned ( )
357
- } ) ;
358
- Ok ( projected)
354
+ f. arguments [ 0 ] . clone ( )
359
355
}
360
- _ => {
356
+ ScalarExpr :: FunctionCall ( _ ) => {
361
357
warn ! ( "cluster key expr is not a (suitable) tuple expression" ) ;
362
- Ok ( None )
358
+ return Ok ( None ) ;
363
359
}
364
- }
360
+ _ => scalar_expr,
361
+ } ;
362
+ let projected = left_most_expr
363
+ . try_project_column_binding ( |binding| column_map. get ( & binding. column_name ) . cloned ( ) ) ;
364
+ Ok ( projected)
365
365
}
366
366
367
367
async fn build_min_max_group_by_left_most_cluster_key_expr_plan (
You can’t perform that action at this time.
0 commit comments