diff --git a/datafusion/proto/src/physical_plan/mod.rs b/datafusion/proto/src/physical_plan/mod.rs index 46d2c8a52d5b..64e462d1695f 100644 --- a/datafusion/proto/src/physical_plan/mod.rs +++ b/datafusion/proto/src/physical_plan/mod.rs @@ -1104,7 +1104,7 @@ impl AsExecutionPlan for protobuf::PhysicalPlanNode { &sink_schema, extension_codec, ) - .map(|item| LexRequirement::from(item)) + .map(LexRequirement::from) }) .transpose()?; Ok(Arc::new(DataSinkExec::new(