diff --git a/datafusion/datasource-arrow/src/source.rs b/datafusion/datasource-arrow/src/source.rs
index 30af5a8bee8ab..8cd7e3ff596b4 100644
--- a/datafusion/datasource-arrow/src/source.rs
+++ b/datafusion/datasource-arrow/src/source.rs
@@ -408,16 +408,15 @@ impl FileSource for ArrowSource {
datafusion_physical_plan::apply_expression_roots(self.projection.source.iter(), f)
}
- /// Emit an `ArrowScan` node wrapping the shared base config and recording
- /// which Arrow IPC format (file or stream) this source reads.
+ /// Emit an `ArrowSourceNode` recording which Arrow IPC format (file or
+ /// stream) this source reads.
#[cfg(feature = "proto")]
- fn try_to_proto(
+ fn try_to_proto_file_source(
&self,
- base: &FileScanConfig,
- ctx: &datafusion_physical_plan::proto::ExecutionPlanEncodeCtx<'_>,
- ) -> Result