diff --git a/datafusion/core/src/physical_planner.rs b/datafusion/core/src/physical_planner.rs index 519bcf2a20963..f2c9da7eb9744 100644 --- a/datafusion/core/src/physical_planner.rs +++ b/datafusion/core/src/physical_planner.rs @@ -213,7 +213,11 @@ fn create_physical_name(e: &Expr, is_first_expr: bool) -> Result { let stop = create_physical_name(stop, false)?; format!("{expr}[{start}:{stop}]") } - GetFieldAccess::ListStride { start, stop, stride } => { + GetFieldAccess::ListStride { + start, + stop, + stride, + } => { let start = create_physical_name(start, false)?; let stop = create_physical_name(stop, false)?; let stride = create_physical_name(stride, false)?; diff --git a/datafusion/proto/src/logical_plan/to_proto.rs b/datafusion/proto/src/logical_plan/to_proto.rs index 1eff752e9d18c..69c7c6fe91048 100644 --- a/datafusion/proto/src/logical_plan/to_proto.rs +++ b/datafusion/proto/src/logical_plan/to_proto.rs @@ -1041,15 +1041,17 @@ impl TryFrom<&Expr> for protobuf::LogicalExprNode { }, )) } - GetFieldAccess::ListStride { start, stop, stride } => { - protobuf::get_indexed_field::Field::ListStride(Box::new( - protobuf::ListStride { - start: Some(Box::new(start.as_ref().try_into()?)), - stop: Some(Box::new(stop.as_ref().try_into()?)), - stride: Some(Box::new(stride.as_ref().try_into()?)), - }, - )) - } + GetFieldAccess::ListStride { + start, + stop, + stride, + } => protobuf::get_indexed_field::Field::ListStride(Box::new( + protobuf::ListStride { + start: Some(Box::new(start.as_ref().try_into()?)), + stop: Some(Box::new(stop.as_ref().try_into()?)), + stride: Some(Box::new(stride.as_ref().try_into()?)), + }, + )), }; Self {