From b6c3d2b57b1674995ccf015fe6e3593ce3ffb202 Mon Sep 17 00:00:00 2001 From: comphead Date: Thu, 30 Jan 2025 17:50:25 -0800 Subject: [PATCH] fmt --- native/core/src/parquet/parquet_support.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/native/core/src/parquet/parquet_support.rs b/native/core/src/parquet/parquet_support.rs index 9ab635d1c..ba7e4ddd1 100644 --- a/native/core/src/parquet/parquet_support.rs +++ b/native/core/src/parquet/parquet_support.rs @@ -1869,7 +1869,7 @@ pub(crate) fn register_object_store( session_context: Arc, ) -> Result { let object_store = object_store::local::LocalFileSystem::new(); - let url = ObjectStoreUrl::parse("file://").unwrap(); + let url = ObjectStoreUrl::parse("file://")?; session_context .runtime_env() .register_object_store(url.as_ref(), Arc::new(object_store)); @@ -1884,7 +1884,7 @@ pub(crate) fn register_object_store( // TODO: read the namenode configuration from file schema or from spark.defaultFS let url = ObjectStoreUrl::parse("hdfs://namenode:9000")?; if let Some(object_store) = - datafusion_objectstore_hdfs::object_store::hdfs::HadoopFileSystem::new((&url).as_ref()) + datafusion_objectstore_hdfs::object_store::hdfs::HadoopFileSystem::new(url.as_ref()) { session_context .runtime_env()