We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 38c3557 commit 369ddabCopy full SHA for 369ddab
native/core/src/execution/operators/parquet_writer.rs
@@ -535,8 +535,12 @@ impl ExecutionPlan for ParquetWriterExec {
535
DataFusionError::Execution(format!("Failed to close writer: {}", e))
536
})?;
537
538
- // Get file size
539
- let file_size = std::fs::metadata(&part_file)
+ // Get file size - strip file:// prefix if present for local filesystem access
+ let local_path = part_file
540
+ .strip_prefix("file://")
541
+ .or_else(|| part_file.strip_prefix("file:"))
542
+ .unwrap_or(&part_file);
543
+ let file_size = std::fs::metadata(local_path)
544
.map(|m| m.len() as i64)
545
.unwrap_or(0);
546
0 commit comments