Skip to content

Commit cbd9b1e

Browse files
committed
fixup! Seperate drop table clean-ups
1 parent 45c7157 commit cbd9b1e

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

  • datafusion/core/src/execution/context

datafusion/core/src/execution/context/mod.rs

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1426,10 +1426,13 @@ impl SessionContext {
14261426
{
14271427
schema.deregister_table(&table)?;
14281428
if table_type == TableType::Base {
1429-
if let Some(lfc) = self.runtime_env().cache_manager.get_list_files_cache() {
1429+
if let Some(lfc) = self.runtime_env().cache_manager.get_list_files_cache()
1430+
{
14301431
lfc.drop_table_entries(&Some(table_ref.clone()))?;
14311432
}
1432-
if let Some(fsc) = self.runtime_env().cache_manager.get_file_statistic_cache() {
1433+
if let Some(fsc) =
1434+
self.runtime_env().cache_manager.get_file_statistic_cache()
1435+
{
14331436
fsc.drop_table_entries(&Some(table_ref.clone()))?;
14341437
}
14351438
return Ok(true);

0 commit comments

Comments
 (0)