From e116c2870dd6aaddfa67a6fbc99dfee0ebc664d8 Mon Sep 17 00:00:00 2001 From: discord9 Date: Thu, 23 Apr 2026 15:51:09 +0800 Subject: [PATCH] dedup a bit Signed-off-by: discord9 --- src/query/src/optimizer/windowed_sort.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/query/src/optimizer/windowed_sort.rs b/src/query/src/optimizer/windowed_sort.rs index 733155c636..4a8e184055 100644 --- a/src/query/src/optimizer/windowed_sort.rs +++ b/src/query/src/optimizer/windowed_sort.rs @@ -253,11 +253,12 @@ fn is_time_index_column( } if let Some(region_scan_exec) = plan.as_any().downcast_ref::() { - return Ok(matches!( - plan.schema().field(column_expr.index()).data_type(), - DataType::Timestamp(_, _) - ) && plan.schema().field(column_expr.index()).name().as_ref() - == region_scan_exec.time_index()); + let schema = plan.schema(); + let column_field = schema.field(column_expr.index()); + return Ok( + matches!(column_field.data_type(), DataType::Timestamp(_, _)) + && column_field.name().as_ref() == region_scan_exec.time_index(), + ); } let Some(child) = passthrough_child(plan.as_ref()) else {