Skip to content

Commit 34ee8dd

Browse files
committed
fix: remove unused code and added check if table exists in register_table
Signed-off-by: Alexander Falk <[email protected]>
1 parent 3699cf7 commit 34ee8dd

File tree

1 file changed

+3
-12
lines changed
  • crates/core/src/data_catalog/storage

1 file changed

+3
-12
lines changed

crates/core/src/data_catalog/storage/mod.rs

Lines changed: 3 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -105,17 +105,6 @@ impl ListingSchemaProvider {
105105
let mut delta_table = delta_table.clone();
106106
delta_table.load().await?;
107107
*table = Arc::from(delta_table);
108-
//match delta_table.load().await {
109-
// Ok(()) => {
110-
// // Add the table back to the DashMap
111-
// }
112-
// Err(err) => {
113-
// return Err(DataFusionError::Internal(format!(
114-
// "Cannot load delta table. See stacktrace: {}",
115-
// err.to_string()
116-
// )))
117-
// }
118-
//}
119108
}
120109
}
121110
}
@@ -159,7 +148,9 @@ impl SchemaProvider for ListingSchemaProvider {
159148
name: String,
160149
table: Arc<dyn TableProvider>,
161150
) -> datafusion_common::Result<Option<Arc<dyn TableProvider>>> {
162-
self.tables.insert(name, table.clone());
151+
if !self.table_exist(name.as_str()) {
152+
self.tables.insert(name, table.clone());
153+
}
163154
Ok(Some(table))
164155
}
165156

0 commit comments

Comments
 (0)