diff --git a/datafusion/src/physical_plan/parquet.rs b/datafusion/src/physical_plan/parquet.rs index 6ea3bdd06e37..c92e60d2946b 100644 --- a/datafusion/src/physical_plan/parquet.rs +++ b/datafusion/src/physical_plan/parquet.rs @@ -167,7 +167,7 @@ impl NoopParquetMetadataCache { impl ParquetMetadataCache for NoopParquetMetadataCache { fn metadata(&self, _key: &str, file: &File) -> Result> { - Ok(Arc::new(footer::parse_metadata(file, &None)?)) + Ok(Arc::new(footer::parse_metadata(file, &None)?.0)) } } @@ -203,7 +203,7 @@ impl ParquetMetadataCache for LruParquetMetadataCache { match self.cache.get(&k) { Some(metadata) => Ok(metadata), None => { - let metadata = Arc::new(footer::parse_metadata(file, &None)?); + let metadata = Arc::new(footer::parse_metadata(file, &None)?.0); self.cache.insert(k, metadata.clone()); Ok(metadata) }