File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1869,7 +1869,7 @@ pub(crate) fn register_object_store(
18691869 session_context : Arc < SessionContext > ,
18701870) -> Result < ObjectStoreUrl , ExecutionError > {
18711871 let object_store = object_store:: local:: LocalFileSystem :: new ( ) ;
1872- let url = ObjectStoreUrl :: parse ( "file://" ) . unwrap ( ) ;
1872+ let url = ObjectStoreUrl :: parse ( "file://" ) ? ;
18731873 session_context
18741874 . runtime_env ( )
18751875 . register_object_store ( url. as_ref ( ) , Arc :: new ( object_store) ) ;
@@ -1884,7 +1884,7 @@ pub(crate) fn register_object_store(
18841884 // TODO: read the namenode configuration from file schema or from spark.defaultFS
18851885 let url = ObjectStoreUrl :: parse ( "hdfs://namenode:9000" ) ?;
18861886 if let Some ( object_store) =
1887- datafusion_objectstore_hdfs:: object_store:: hdfs:: HadoopFileSystem :: new ( ( & url) . as_ref ( ) )
1887+ datafusion_objectstore_hdfs:: object_store:: hdfs:: HadoopFileSystem :: new ( url. as_ref ( ) )
18881888 {
18891889 session_context
18901890 . runtime_env ( )
You can’t perform that action at this time.
0 commit comments