Skip to content

Commit fb5fbd1

Browse files
committed
fix pb.
1 parent d636155 commit fb5fbd1

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

datafusion/proto/src/physical_plan/from_proto.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -559,7 +559,7 @@ impl TryFrom<&protobuf::PartitionedFile> for PartitionedFile {
559559
.map(|v| v.try_into())
560560
.collect::<Result<Vec<_>, _>>()?,
561561
range: val.range.as_ref().map(|v| v.try_into()).transpose()?,
562-
statistics: val.statistics.as_ref().map(|v| v.try_into()).transpose()?,
562+
statistics: val.statistics.as_ref().map(|v| v.try_into().map(Arc::new)).transpose()?,
563563
extensions: None,
564564
})
565565
}

datafusion/proto/src/physical_plan/to_proto.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -527,7 +527,7 @@ impl TryFrom<&PartitionedFile> for protobuf::PartitionedFile {
527527
.map(|v| v.try_into())
528528
.collect::<Result<Vec<_>, _>>()?,
529529
range: pf.range.as_ref().map(|r| r.try_into()).transpose()?,
530-
statistics: pf.statistics.as_ref().map(|s| s.into()),
530+
statistics: pf.statistics.as_ref().map(|s| s.as_ref().into()),
531531
})
532532
}
533533
}

0 commit comments

Comments
 (0)