File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -26,7 +26,7 @@ use datafusion::{
2626 } ,
2727 prelude:: SessionContext ,
2828} ;
29- use log:: info;
29+ use log:: { debug , info} ;
3030use std:: path:: Path ;
3131#[ cfg( feature = "vortex" ) ]
3232use vortex_datafusion:: VortexFormat ;
@@ -50,7 +50,7 @@ fn detect_format(extension: &str) -> Result<(Arc<dyn FileFormat>, &'static str)>
5050
5151pub async fn register_db ( ctx : & SessionContext , db_config : & DbConfig ) -> Result < ( ) > {
5252 info ! ( "registering tables to database" ) ;
53- let tables_url = db_config. path . join ( "tables" ) ?;
53+ let tables_url = db_config. path . join ( "tables/ " ) ?;
5454 let listing_tables_url = ListingTableUrl :: parse ( tables_url. clone ( ) ) ?;
5555 let store_url = listing_tables_url. object_store ( ) ;
5656 let store = ctx. runtime_env ( ) . object_store ( store_url) ?;
@@ -104,7 +104,9 @@ pub async fn register_db(ctx: &SessionContext, db_config: &DbConfig) -> Result<(
104104 . join ( & format ! ( "{catalog_name}/" ) ) ?
105105 . join ( & format ! ( "{schema_name}/" ) ) ?
106106 . join ( & format ! ( "{table_name}/" ) ) ?;
107+
107108 let table_url = ListingTableUrl :: parse ( p) ?;
109+ debug ! ( "...table url: {table_url:?}" ) ;
108110
109111 // List files in the table directory to detect the format
110112 let files = store. list_with_delimiter ( Some ( & table_path) ) . await ?;
You can’t perform that action at this time.
0 commit comments