diff --git a/datafusion/proto/src/physical_plan/mod.rs b/datafusion/proto/src/physical_plan/mod.rs index ee42c304ebf91..f890c3ece6204 100644 --- a/datafusion/proto/src/physical_plan/mod.rs +++ b/datafusion/proto/src/physical_plan/mod.rs @@ -557,7 +557,7 @@ impl AsExecutionPlan for PhysicalPlanNode { runtime, extension_codec )?; - Ok(Arc::new(CrossJoinExec::try_new(left, right)?)) + Ok(Arc::new(CrossJoinExec::new(left, right))) } PhysicalPlanType::Empty(empty) => { let schema = Arc::new(convert_required!(empty.schema)?);